Fix duplicate field on Kafka component
diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
index dff7fd2..aa536ea 100644
--- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
+++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaComponent.java
@@ -39,10 +39,9 @@
private KafkaClientFactory kafkaClientFactory = new DefaultKafkaClientFactory();
@Metadata(autowired = true, label = "consumer,advanced")
private PollExceptionStrategy pollExceptionStrategy;
- @Metadata(label = "consumer", defaultValue = "ERROR_HANDLER")
- private PollOnError pollOnError = PollOnError.ERROR_HANDLER;
public KafkaComponent() {
+ configuration.setPollOnError(PollOnError.ERROR_HANDLER);
}
public KafkaComponent(CamelContext context) {
@@ -64,7 +63,6 @@
KafkaConfiguration copy = getConfiguration().copy();
endpoint.setConfiguration(copy);
endpoint.getConfiguration().setTopic(remaining);
- endpoint.getConfiguration().setPollOnError(pollOnError);
setProperties(endpoint, parameters);
@@ -142,21 +140,4 @@
this.pollExceptionStrategy = pollExceptionStrategy;
}
- public PollOnError getPollOnError() {
- return pollOnError;
- }
-
- /**
- * What to do if kafka threw an exception while polling for new messages.
- *
- * The default is ERROR_HANDLER.
- *
- * DISCARD will discard the message and continue to poll next message. ERROR_HANDLER will use Camel's error handler
- * to process the exception, and afterwards continue to poll next message. RECONNECT will re-connect the consumer
- * and try poll the message again RETRY will let the consumer retry polling the same message again STOP will stop
- * the consumer (have to be manually started/restarted if the consumer should be able to consume messages again)
- */
- public void setPollOnError(PollOnError pollOnError) {
- this.pollOnError = pollOnError;
- }
}
