用于 Kafka SQL 的 Java API

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 .