Andrew Mashenkov created IGNITE-7752:

             Summary: Update Ignite KafkaStreamer to use new KafkaConsmer 
                 Key: IGNITE-7752
             Project: Ignite
          Issue Type: Task
          Components: streaming
            Reporter: Andrew Mashenkov
             Fix For: 2.5

Seems, for now it is impossible to use new style KafkaConsumer configuration in 

The issue here is Ignite useĀ 
kafka.consumer.Consumer.createJavaConsumerConnector() method which creates old 
consumer (ZookeeperConsumerConnector).

We should create a new KafkaConsumer instead which looks like support both, old 
and new style configs.

This message was sent by Atlassian JIRA

Reply via email to