[
https://issues.apache.org/jira/browse/IGNITE-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215584#comment-15215584
]
Roman Shtykh commented on IGNITE-2730:
--------------------------------------
Denis,
1. Thank you for the pointers on primary node check! I implemented this check
in the similar manner. Please have a look.
And you are absolutely right -- the current code is not sufficient to guarantee
data safety in the queue. Let's treat it as a future work.
2. Using Ignite default marshaller would be nice, but what if the user access
cache events in Kafka without Ignite instance (using Kafka client rather than
Kafka Connect), like it is done in the tests (_checkDataDelivered(...)_)? It
should not be necessarily _JdkMarshaller_, but we should consider having a
de/serializer that can be used with Kafka Connect even without the knowledge of
the grid.
> Ignite Events Source Streaming to Kafka
> ---------------------------------------
>
> Key: IGNITE-2730
> URL: https://issues.apache.org/jira/browse/IGNITE-2730
> Project: Ignite
> Issue Type: New Feature
> Components: streaming
> Reporter: Roman Shtykh
> Assignee: Roman Shtykh
> Labels: community
>
> Streaming specified Ignite events
> (https://apacheignite.readme.io/docs/events) to Kafka via Kafka Connect.
> It has to be added to org.apache.ignite.stream.kafka.connect package.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
