Eric C
Eric C

Reputation: 165

Java API for Kafka SQL

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

Answers (1)

miguno
miguno

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

Related Questions