如何在不停止和启动 Confluent 的情况下重新加载 Kafka Connect source/sink .jar?

How to reload Kafka Connect source/sink .jar without stopping and starting Confluent?

我正在构建我的 Kafka Connect source/sink 连接器,过程如下:

  1. 编辑代码并导出 .jar
  2. 汇流开始
  3. 合流负载
  4. 融合状态
  5. 融合日志连接
  6. 合流卸载
  7. 合流停止
  8. 重复

所以我每次更改代码时都会启动和停止所有 Confluent,这需要一段时间。有没有一种方法可以加快这个过程,让它使用新的 .jar 或其他东西,而无需重新启动整个过程,从而使调试过程更加顺利?

您只需要停止和启动 connect 进程,而不是整个 Confluent Platform

在任何情况下,Kafka Connect 都需要重新启动 JVM 才能加载新代码

在生产环境中,您可能会使用 systemctl 重新启动连接进程