Apache Kafka 连接 Springboot

Question

我正在尝试查找 kafka 与 springboot 连接的示例。看起来kafka connect没有spring boot集成。有人能指出我正确的方向，以便能够监听 mysql db 的变化吗？

Answer 1

Kafka Connect 并不真正需要 Spring Boot，因为您无需为它编写任何代码，而且在分布式模式下作为集群运行时，它确实效果最好，而不是嵌入到其他应用程序中。我想如果您确实想这样做，那么您可以复制源代码的相关部分，但这当然不是使用 Spring Boot，而且您必须自己将其全部连接起来

该框架本身由一些已经编写好的核心 Java 依赖项（Debezium 或 Confluent JDBC 连接器，对于您的 mysql 示例）和两个配置文件组成。一个用于 Kafka Connect 了解引导服务器、序列化程序等，另一个用于实际的 MySQL 连接器。