我已经将Kafka支持集成到我们的服务器中并对其进行了测试。它在我的开发环境中运行良好,但其他开发人员无法在他们的开发环境中运行。这个问题类似于我在自己的开发环境中遇到的问题,但我不明白为什么它在我的机器上工作,而不是在他们的机器上工作。
基本上,我们在docker-compose堆栈中运行Kafka。在这两个环境中,docker-compose ps都显示运行相同的配置。
$ docker-compose ps
Name Command State
我使用Debezium连接器版本0.8来捕获MySQL数据库中的更改,并将其移到Kafka。我使用了一个用于MySQL的容器,另一个用于连接器,另一个用于Kafka。
当我停止Docker (docker-compose down)并再次启动Docker时,通常会出现以下错误:
org.apache.kafka.connect.errors.ConnectException: The db history topic is missing. You may attempt to recover it by reconfiguring the connector to SCHEMA_ONLY_R
我正在尝试将我的spring boot应用程序连接到Kafka主题,但它看起来spring正在尝试连接到localhost而不是docker ip,因为我在windows上使用docker。这是spring上的Kafka配置类: @Configuration
public class KafkaConfig {
@Bean
public ProducerFactory<String,String> producerFactory()
{
Map<String,Object> config = new HashMap<>();
confi
我刚接触docker,在Docker容器中运行Kafka代理时遇到了问题。我和kafka开发了spring boot应用程序,生产者和消费者在同一个应用程序中。应用程序在没有docker的情况下成功运行,但当我尝试通过主机上的docker容器运行它时,会出现以下错误:
org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not