在文档kafka connect中，workers被描述为进程，因此在我的理解中，cpu的核心。但是在同一个文档中，它们是用来提供自动容错的（在它们的分布式模式中），所以在我的理解中，不同的机器，因为进程级的容错是没有意义的。有人能启发我吗？
7hiiyaii1#
kafka连接工作进程是一个jvm进程。您可以在配置为集群的分布式模式下运行多个kafka connect worker，如果一个worker死亡，则工作（任务）将分布在其余的worker中。通常，您会为每台机器部署一个kafka connect worker。在一台机器上以分布式模式运行多个kafka connect worker通常是没有意义的。我没有测试它，但我不相信Kafka连接工人是绑在一个cpu。更多说明请参见：https://youtu.be/onk3lb8z-za?t=1337 （幻灯片：https://rmoff.dev/bbuzz19-kafka-connect)
1条答案
按热度按时间7hiiyaii1#
kafka连接工作进程是一个jvm进程。
您可以在配置为集群的分布式模式下运行多个kafka connect worker，如果一个worker死亡，则工作（任务）将分布在其余的worker中。
通常，您会为每台机器部署一个kafka connect worker。在一台机器上以分布式模式运行多个kafka connect worker通常是没有意义的。
我没有测试它，但我不相信Kafka连接工人是绑在一个cpu。
更多说明请参见：https://youtu.be/onk3lb8z-za?t=1337 （幻灯片：https://rmoff.dev/bbuzz19-kafka-connect)