Page History

...

It is useful to take a look at:

• SocketStreamer - reference implementation of custom data streamer as TCP socket server.
• WordsSocketStreamerServer and WordsSocketStreamerClient - example of SocketStreamer usage.

Basic Concepts

The purpose of streamers is data ingesting from various sources (e.g. TCP socket or Kafka) and streaming them into Ignite cache for further processing. The Ignite provides IgniteDataStreamer API that allows stream data into cache and convenient StreamAdapter that wraps data streamer instance and provides basis for custom streamer implementation.

...