mgenereu opened a new issue #361: URL: https://github.com/apache/camel-kafka-connector/issues/361
I'm getting an exception on this line in the code. Best I can tell, it's trying to get the endpoint from the Camel Context before the endpoint has been upgraded to a PollingConsumer on the line afterwards. `direct` doesn't have these parameters. https://github.com/apache/camel-kafka-connector/blob/4a73d046f0bbb8c2265bddc315689a7fb39f3871/core/src/main/java/org/apache/camel/kafkaconnector/CamelSourceTask.java#L109 ``` org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000 due to: Error binding property (pollingConsumerBlockTimeout=0) with name: pollingConsumerBlockTimeout on bean: direct://end?pollingConsumerBlockTimeout=0&pollingConsumerBlockWhenFull=true&pollingConsumerQueueSize=1000 with value: 0 ``` ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org
