Reputation: 165
I have a Kafka Topic and I want to Get the last 5 minutes of data.
I Know that I can do that with Kafka SQL
CREATE STREAM test_stream ( name varchar, age int ) WITH (kafka_topic='my_topic', value_format='JSON')
And
SELECT * FROM test_stream WHERE ROWTIME <= 1563356280000;
I want to do the same for a Web Service Java, and I can't find the good libraries, have anyone faced this issue ?
Upvotes: 1
Views: 1425
Reputation: 15057
I want to do the same for a Web Service Java, and I can't find the good libraries, have anyone faced this issue ?
You can use the KSQL REST API.
If, however, you want to write your stream processing code natively in Java, you should take a look at Kafka Streams.
Upvotes: 4