我将 Kafka 用于多种目的，但我想使用 Kafka 的连接 API，但我无法理解为什么使用 Kafka 连接而不是编写我们自己的消费者组并以任何方式编写消息的差异数据库，无需编写复杂的东西，也无需像 Kafka-connect 中的 confluence 那样添加其他包。
最佳答案
Connect 作为一个框架负责故障转移，您还可以在分布式模式下运行它以扩展数据导入/导出“作业”。因此，Connect 确实是一种“即发即忘”的体验。此外，对于 Connect，您不需要编写任何代码 - 只需配置连接器即可。
如果你手动构建这个，你基本上可以解决 Connect 已经解决的问题(即重新发明轮子)。不要低估这项任务的复杂性——表面上听起来很简单，但实际上它看起来更复杂。
关于java - Kafka与Cassandra数据库连接，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/42801608/