[
https://issues.apache.org/jira/browse/IGNITE-2730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15201089#comment-15201089
]
Roman Shtykh commented on IGNITE-2730:
--------------------------------------
Some implementation details for reviewers:
- I use a distributed queue as a buffer that is polled by Kafka. This is done
to keep cache event data safe between polls.
- Schema facilities of Kafka Connect are not used -- cache events are
marshalled with _JDKMarshaller_ and sent to Kafka. Later they can be
deserialized with the provided _CacheEventDeserializer_, as done in the test
code.
- Kafka partition keys are specified in the current implementation. If there
are requests from users, we can enhance.
> 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)
