Page History

...

1. Chose model that data streamer will be implement (server or client).D
2. Define new data streamer class that extends StreamAdapter.
3. Implement life cycle management methods if needed. Usually developer will want to have control over data source resources such as JMS sessions, HTTP/socket connections, Kafka consumers and so on.
4. Implement logic of data consuming from data source. For example: process JMS message in corresponding listener, accept connections and read data from it, consume messages from Kafka topics and so on.
5. Implement data conversion from data source specific format to Java object. For example: convert JMS Message instances, convert bytes received from socket, convert bytes consumed from Kafka topics and so on.