Java API 对于 Kafka SQL

Question

我有一个 Kafka 主题，我想获取最后 5 分钟的数据。

我知道我可以用 Kafka 做到这一点 SQL

CREATE STREAM test_stream ( name varchar, age int ) WITH (kafka_topic='my_topic', value_format='JSON')

和

SELECT * FROM test_stream WHERE ROWTIME <= 1563356280000;

我想为 Web 服务做同样的事情 Java，但我找不到好的库，有人遇到过这个问题吗？

Answer 1

I want to do the same for a Web Service Java, and I can't find the good libraries, have anyone faced this issue ?

您可以使用 KSQL REST API.

但是，如果您想在 Java 中原生编写流处理代码，您应该看看 Kafka Streams。

Java API for Kafka SQL