Apache Kafka 与 Springboot 连接
Apache Kafka Connect With Springboot
我正在尝试查找 kafka 与 springboot 连接的示例。看起来没有 spring 用于 kafka connect 的启动集成。有人能给我指出正确的方向，让我能够听到 mysql db 上的变化吗？
Kafka Connect 并不真正需要 Spring 启动，因为您无需为其编写任何代码，并且当 运行 在分布式模式下，作为集群而非嵌入式时，它确实工作得最好在其他（单实例）应用程序中。我想如果你真的想这样做，那么你可以复制 the source code 的相关部分，但这当然不是使用 Spring 引导，你必须自己连接它
框架本身包含一些已经编写好的核心 Java 依赖项（Debezium 或 Confluent JDBC 连接器，对于您的 mysql 示例）和两个配置文件。一个用于 Kafka Connect 了解 bootstrap 服务器、序列化器等，另一个用于实际的 MySQL 连接器。所以，如果你想单独使用 Kafka Connect 运行，那么只需在 Spring 应用程序中编写消费者即可。
Kafka Connect 本身的替代方案是在 Spring 应用程序（Spring Integration）或 Spring Cloud Dataflow 中使用 Apache Camel 并与那些 Kafka“组件”（其中没有使用 Connect API，AFAIK)
另一个选项，专门用于收听 MySQL，是在您的代码中使用 Debezium Engine。
我正在尝试查找 kafka 与 springboot 连接的示例。看起来没有 spring 用于 kafka connect 的启动集成。有人能给我指出正确的方向，让我能够听到 mysql db 上的变化吗？
Kafka Connect 并不真正需要 Spring 启动，因为您无需为其编写任何代码，并且当 运行 在分布式模式下，作为集群而非嵌入式时，它确实工作得最好在其他（单实例）应用程序中。我想如果你真的想这样做，那么你可以复制 the source code 的相关部分，但这当然不是使用 Spring 引导，你必须自己连接它
框架本身包含一些已经编写好的核心 Java 依赖项（Debezium 或 Confluent JDBC 连接器，对于您的 mysql 示例）和两个配置文件。一个用于 Kafka Connect 了解 bootstrap 服务器、序列化器等，另一个用于实际的 MySQL 连接器。所以，如果你想单独使用 Kafka Connect 运行，那么只需在 Spring 应用程序中编写消费者即可。
Kafka Connect 本身的替代方案是在 Spring 应用程序（Spring Integration）或 Spring Cloud Dataflow 中使用 Apache Camel 并与那些 Kafka“组件”（其中没有使用 Connect API，AFAIK)
另一个选项，专门用于收听 MySQL，是在您的代码中使用 Debezium Engine。