我已经安装了Kafka ">kafka_2.12-0.11.0.0"。
开始了zookeper和Kafka 服务器的服务。
然后我在IntelliJ上创建了一个Java项目(包括kafka lib(。
我还包括了JDBC连接所需的SQLitejar。
我最初想到使用confluent.kafka-connect,但由于我的是基于Windows的机器,CLIplatform不起作用。
因此,我编写了一个独立的Java程序来连接到我的sqlite DB获取的数据,并使用自定义Kafka-Producer程序将其作为消息发送,从而创建一个主题"连接测试"。
我使用自定义的Kafka-Consumer程序收到了相同的数据。 此测试的目的是看看我是否可以对现有的基于 Windows 的企业应用程序执行相同的操作,以将数据流式传输到数据分析平台的仓库中。 我知道我已经在独立模式下完成了它,但我的方向是否正确?
您能否建议是否有更好的方法将我的企业应用程序(基于 Java 的自定义 API + oracle DB + Oracle DB + Oracle DB 之上的另一层(与 Kafka 集成?
非常感谢您的帮助。
Kafka Connect 是 Apache Kafka 的一部分,是与其他系统(包括数据库(集成的推荐方式。本文介绍了与 Oracle 集成的具体选项,本次演讲将介绍它的实际应用。
因为我是基于Windows的机器CLIplatform不起作用。
Kafka Connect应该可以在Windows上运行。我不确定你说的CLIplatform
是什么意思,因为它是基于Java的,它应该在Windows上运行,如果没有,你可以使用Docker镜像。
免责声明:我在Confluent工作,并撰写了上述文章链接到