找不到 kafka StoreBuilder class

Question

我正在使用 kafka 0.11。我在 kafka-streams-0.11.0.0.jar.
中找不到 StoreBuilder class 知道有什么问题吗？

Answer 1

Kafka class 添加了 1.0.0 - KAFKA-5650

幸运的是，较新的 Kafka Streams 库向后兼容 0.11.0 代理（假设这就是您选择该版本的原因）

我注意到你的 class 名字是 "test jdbc"，所以我建议使用现有的 Kafka Connect JDBC 产品而不是开始重新发明它

I wanted to transform the incoming stream data using kstream.transform() function and then feed the transformed data to Oracle db table VIA JdbcSinkConnector

您可能想尝试制作或使用 Simple Message Transform (SMT)。让 JdbcSink 连接器为您处理从 Kafka 获取记录，并且连接器的 属性 配置位于单独的位置，并且可重复使用，而不是特定于您的代码。

Transformation 接口有一个 apply() 方法，您可以根据需要转换消息，这实际上与 kstream.map(...).to("topic") 的概念相同，但目的地不是单独的Kafka 主题