is custom StreamSingleTupleExtractor compulsory in kafka-ignite-sink connector?

[shubhamshirur <sh...@gmail.com>]

Hi I don't how to create custom extractor. Is it compulsory to create SSTE
every time? My data is simple String key and String value in the topic.
Thank you



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/

Re: is custom StreamSingleTupleExtractor compulsory in kafka-ignite-sink connector?

[Alexander Korenshteyn <al...@gmail.com>]

Hi,
  StreamSingleTupleExtractor is a helper interface used when you need to
process your incoming messages before streaming them.

see:
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/stream/StreamAdapter.html
Its use by the socket streamer:
https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/stream/socket/SocketStreamer.html

see:
https://github.com/apache/ignite/blob/b1529fbd7d42e3f3a5500a217a2b8b21acbb4189/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java#L170

actual use of the tuple extractor:
https://github.com/apache/ignite/blob/b1529fbd7d42e3f3a5500a217a2b8b21acbb4189/modules/core/src/main/java/org/apache/ignite/stream/StreamAdapter.java#L173


If you have a simple key/value pair that you've already extracted from
kaflka, then calling streamer.addData(K,v) is good enough.
see: https://ignite.apache.org/docs/latest/data-streaming

Thanks, Alex

On Tue, May 18, 2021 at 5:40 AM shubhamshirur <sh...@gmail.com>
wrote:

> Hi I don't how to create custom extractor. Is it compulsory to create SSTE
> every time? My data is simple String key and String value in the topic.
> Thank you
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>