[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15132390#comment-15132390 ] Anton Vinogradov commented on IGNITE-2016: -- Seems that you changes related to IGNITE-2016 broke

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121847#comment-15121847 ] Vishal Garg commented on IGNITE-2016: - Roman, sounds good. -:) > Update KafkaStreamer to fit new

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121086#comment-15121086 ] Denis Magda commented on IGNITE-2016: - [~roman_s] Reviewed your latest changes. Please go ahead and

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15121099#comment-15121099 ] Roman Shtykh commented on IGNITE-2016: -- Denis, Thanks a lot! I will prepare docs for both versions.

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15122791#comment-15122791 ] Roman Shtykh commented on IGNITE-2016: -- Vishal, Here is the snippet I prepared for Kafka Streamer

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116472#comment-15116472 ] Roman Shtykh commented on IGNITE-2016: -- Denis, Thank you. Please see my comments in PR. I think it

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15114992#comment-15114992 ] Denis Magda commented on IGNITE-2016: - [~roman_s] Thanks, I've finished with the review. Left a

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15111297#comment-15111297 ] Denis Magda commented on IGNITE-2016: - Roman, Please open a pull-request. The initial link I used

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15089227#comment-15089227 ] Denis Magda commented on IGNITE-2016: - Roman, thanks! Sorry for the delay. I'll review the changes in

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15071842#comment-15071842 ] Roman Shtykh commented on IGNITE-2016: -- Denis, Thanks for details on _IgniteDataStreamer_'s

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15071500#comment-15071500 ] Denis Magda commented on IGNITE-2016: - Roman, According to {{SinkTask.put(...)}} API

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15071613#comment-15071613 ] Roman Shtykh commented on IGNITE-2016: -- Denis, Yes, it makes sense. Thank you. The only remaining

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15071825#comment-15071825 ] Denis Magda commented on IGNITE-2016: - Roman, Agree, there is no need to setup auto-flushing on

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15069479#comment-15069479 ] Denis Magda commented on IGNITE-2016: - Roman, Ok, finally I've figured out what is the difference

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15069556#comment-15069556 ] Roman Shtykh commented on IGNITE-2016: -- Denis, Thanks for your suggestions. I agree and will

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15070511#comment-15070511 ] Roman Shtykh commented on IGNITE-2016: -- I think using _IgniteDataStreamer_ is not a very good idea

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15069583#comment-15069583 ] Denis Magda commented on IGNITE-2016: - What do you mean under the exactly-once delivery? Is it

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15069383#comment-15069383 ] Denis Magda commented on IGNITE-2016: - Roman, thanks for the clarification. Please give me some time

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15067927#comment-15067927 ] Roman Shtykh commented on IGNITE-2016: -- Hi Denis, I think Anton had similar questions when he

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15067859#comment-15067859 ] Denis Magda commented on IGNITE-2016: - Hi Roman, before taking look at the details of the

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15068100#comment-15068100 ] Roman Shtykh commented on IGNITE-2016: -- Denis, I would like to add that probably we shouldn't treat

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057859#comment-15057859 ] Denis Magda commented on IGNITE-2016: - Roman, thanks for the contribution! Someone from the community

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15058209#comment-15058209 ] Vishal Garg commented on IGNITE-2016: - Thanks [~roman_s] > Update KafkaStreamer to fit new features

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15057479#comment-15057479 ] Roman Shtykh commented on IGNITE-2016: -- Kafka Connect integration need to be done to adopt to the

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15031233#comment-15031233 ] Roman Shtykh commented on IGNITE-2016: -- Sure, what's your github id? > Update KafkaStreamer to fit

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15031243#comment-15031243 ] Vishal Garg commented on IGNITE-2016: - githu_user_id: gargvish > Update KafkaStreamer to fit new

[jira] [Commented] (IGNITE-2016) Update KafkaStreamer to fit new features introduced in Kafka 0.9

[ https://issues.apache.org/jira/browse/IGNITE-2016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15029745#comment-15029745 ] Vishal Garg commented on IGNITE-2016: - Roman. Please add me to your github branch, curious to see