问我在用卡夫卡对吧？

EN

我安装了卡夫卡"kafka_2.12-0.11.0.0".

启动了zookeper和Kafka-服务器的服务。

然后，我在IntelliJ上创建了一个java项目(包括kafka)。

我还包括了所需的SQLite jar。

我最初考虑使用confluent.kafka连接，但是由于我的机器是基于windows的，所以CLIplatform无法工作。

因此，我编写了一个独立的java程序来连接到我的sqlite获取的数据，并使用一个定制的Kafka-Producer程序将其作为消息发送，创建了一个主题“连接-测试”。

我收到了同样的数据使用一个定制的卡夫卡-消费者程序。这个测试的目的是看我是否可以对现有的基于windows的企业应用程序进行同样的测试，以便将数据流到数据分析平台的仓库中。我知道我是以独立的方式做的，但我是否有正确的方向？

，您能建议我是否有更好的方法将我的企业应用程序(基于java的自定义API + oracle + Oracle之上的另一层)与Kafka?集成起来。

会很感激你的帮助。