diff --git a/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/main/Main.java b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/main/Main.java index 6439b93f4e..3fc667d6b9 100644 --- a/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/main/Main.java +++ b/data-plane/dispatcher/src/main/java/dev/knative/eventing/kafka/broker/dispatcher/main/Main.java @@ -84,7 +84,7 @@ public static void start( consumerConfig.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, CloudEventDeserializer.class.getName()); consumerConfig.put( ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG, - InvalidCloudEventInterceptor.class.getName() + "," + NullCloudEventInterceptor.class.getName()); + NullCloudEventInterceptor.class.getName() + "," + InvalidCloudEventInterceptor.class.getName()); // Read WebClient config JsonObject webClientConfig = Configurations.readPropertiesAsJsonSync(env.getWebClientConfigFilePath());