[
https://issues.apache.org/jira/browse/IGNITE-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15778611#comment-15778611
]
Anil commented on IGNITE-4368:
--
i did couple of tests and noticed this exception in case of network
[
https://issues.apache.org/jira/browse/IGNITE-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15744354#comment-15744354
]
Anil commented on IGNITE-4368:
--
Looks like the issue is related to IGNITE-2766. IGNITE-2766 says about
[
https://issues.apache.org/jira/browse/IGNITE-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15729068#comment-15729068
]
Anil commented on IGNITE-4140:
--
Thank you [~avinogradov] and [~vkulichenko]
> KafkaStreamer should use
[
https://issues.apache.org/jira/browse/IGNITE-4368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anil updated IGNITE-4368:
-
Description:
There is a possibility of data streamer closed exception in the following case
1. Lets says Kafka
Anil created IGNITE-4368:
Summary: Data Streamer closed exception in Kafka Streamer
Key: IGNITE-4368
URL: https://issues.apache.org/jira/browse/IGNITE-4368
Project: Ignite
Issue Type: Bug
[
https://issues.apache.org/jira/browse/IGNITE-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15709025#comment-15709025
]
Anil commented on IGNITE-4140:
--
Hi [~avinogradov]
Thanks for comments.
#1 - Creating new steamer will
[
https://issues.apache.org/jira/browse/IGNITE-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15702469#comment-15702469
]
Anil commented on IGNITE-4140:
--
Hi [~avinogradov]
Could you please review the changes ? Thanks
[
https://issues.apache.org/jira/browse/IGNITE-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Anil reassigned IGNITE-4140:
Assignee: Anil
> KafkaStreamer should use tuple extractor instead of decoders
>
