我试图能够玩一些主题在我的本地机器上。
我想使用Kafkaesque https://kafka.esque.at/
我的Sping Boot 应用程序有以下配置:
我发现了一个docker映像,我添加到Bitnami的docker-compose文件中,它看起来像这样用于设置环境
zookeeper:
image: docker.io/bitnami/zookeeper:3.8
ports:
- "2181:2181"
volumes:
- "zookeeper_data:/bitnami"
environment:
- ALLOW_ANONYMOUS_LOGIN=yes
kafka:
image: docker.io/bitnami/kafka:3.4
ports:
- "9092:9092"
- "9000:9000"
- "9080:8080"
- "9081:9081"
- "9082-9084:9082-9084"
volumes:
- "kafka_data:/bitnami"
environment:
- ALLOW_PLAINTEXT_LISTENER=yes
- KAFKA_ENABLE_KRAFT=no
- KAFKA_CFG_ZOOKEEPER_CONNECT=zookeeper:2181
- KAFKA_CFG_LISTENERS=PLAINTEXT://:9092
depends_on:
- zookeeper
schema-registry:
image: docker.io/bitnami/schema-registry:7.3
ports:
- '8081:8081'
depends_on:
- kafka
environment:
- SCHEMA_REGISTRY_LISTENERS=http://0.0.0.0:8081
- SCHEMA_REGISTRY_KAFKA_BROKERS=PLAINTEXT://kafka:9092
在我的本地应用程序属性中,我这样设置配置
spring.kafka:
bootstrap-servers: localhost:9092
properties:
schema.registry.url: http://localhost:8081
streams:
cleanup.on-startup: true
在kafkaesque(https://kafka.esque.at/)中,我这样设置属性
我的案例是在这里的场景4中展示的https://www.confluent.io/blog/kafka-client-cannot-connect-to-broker-on-aws-on-docker-etc/
1条答案
按热度按时间kgsdhlau1#
我想你应该看看如何在代理之后或在Docker容器中连接到Kafka。最有可能的问题是,分配给容器的IP地址类似于10。x.y.z,当你连接到127。0.0.1.这将破坏客户端(Kafkesque)和服务器(Kafka)之间的Kafka协议。这里是足够好的解释在这个article。
作为替代方案,您可以寻找如何将kafkaesque放入docker容器中。这并不简单,因为GUI应用程序在Docker容器中没有得到很好的支持。