我已经安装了Kafka“Kafka2.12-0.11.0.0”。
启动zookeper和kafka服务器的服务。
然后我在intellij上创建了一个java项目（包括kafka lib）。
我还提供了jdbc连接所需的sqlite jar。
我最初考虑使用confluent.kafka-connect，但由于我的是基于windows的机器，cliplatform无法工作。
因此，我编写了一个独立的java程序来连接sqlitedb获取的数据，并使用定制的kafka producer程序创建了一个主题“connecttest”，将其作为消息发送。
我收到了相同的数据使用自定义Kafka消费程序。这个测试的目的是看看我是否可以对现有的基于windows的企业应用程序执行相同的操作，将数据流传输到数据分析平台的仓库中。我知道我是在独立模式下完成的，但我的方向正确吗？
你能告诉我有没有更好的方法将我的企业应用程序（基于java的定制api+oracledb+oracledb之上的另一层）与kafka集成吗？
非常感谢你的帮助。
1条答案
按热度按时间des4xlb01#
kafka connect是apachekafka的一部分，是与其他系统（包括数据库）集成的推荐方法。本文介绍了与oracle集成的具体选项，并在本次谈话中展示了它的实际应用。
因为我的是基于windows的机器，所以cliplatform不起作用。
Kafka连接应该在windows上工作。我不知道你说的是什么意思
CLIplatform因为它是基于java的，所以应该在windows上运行，如果没有，也可以使用docker映像。免责声明：我为confluent工作，并将上述文章链接到