Andrew Mashenkov created IGNITE-7752:
----------------------------------------
Summary: Update Ignite KafkaStreamer to use new KafkaConsmer
configuration.
Key: IGNITE-7752
URL: https://issues.apache.org/jira/browse/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
KafkaStreamer.
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
(v7.6.3#76005)
