camel-kafka-connector: Exception on endpoint being treated as a polling consumer before createPollingConsumer is called.

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