[IGNITE-7752] Update Ignite KafkaStreamer to use new KafkaConsmer configuration.

• Type: Task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 2.7
• Component/s: streaming
• Labels: newbie streaming
• Flags: Important
• Ignite Flags: Docs Required
• Assignee: Roman Shtykh
• Reporter: Andrey Mashenkov
• Created: 19/Feb/18 13:37
• Updated: 28/Aug/18 09:35
• Resolved: 01/Aug/18 08:00

Description

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.

Issue Links

• links to: GitHub Pull Request #4363