Zipkin Docker不消费kafka "zipkin“主题

Question

目前正在遵循https://github.com/openzipkin/zipkin快速入门，用于zipkin和kafka的docker启动。我设置了一个docker-compose来启动几个服务: kafka、zookeeper、neo4j和zipkin。我通过"KAFKA.BOOTSTRAP.SERVERS: broker:19092“给了zipkin与正常运行的neo4j相同的地址。

zipkin:
image: ghcr.io/openzipkin/zipkin:${TAG:-latest}
container_name: zipkin
depends_on:
  - broker
environment:
  KAFKA.BOOTSTRAP.SERVERS: broker:19092
ports:
  # Port used for the Zipkin UI and HTTP Api
  - 9411:9411

我的Kafka docker-compose部分看起来像这样：

broker:
image: confluentinc/cp-kafka:latest
hostname: broker
container_name: broker
ports:
  - "9092:9092"
  - "9101:9101"
depends_on:
  - zookeeper
environment:
  KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: LISTENER_DOCKER_INTERNAL:PLAINTEXT,LISTENER_DOCKER_EXTERNAL:PLAINTEXT
  KAFKA_ADVERTISED_LISTENERS: LISTENER_DOCKER_INTERNAL://broker:19092,LISTENER_DOCKER_EXTERNAL://${DOCKER_HOST_IP:-127.0.0.1}:9092
  KAFKA_INTER_BROKER_LISTENER_NAME: LISTENER_DOCKER_INTERNAL
  KAFKA_BROKER_ID: 1
  KAFKA_LOG4J_LOGGERS: "kafka.controller=INFO,kafka.producer.async.DefaultEventHandler=INFO,state.change.logger=INFO"
  KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
  KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
  KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS: 0
  KAFKA_CONFLUENT_LICENSE_TOPIC_REPLICATION_FACTOR: 1
  KAFKA_CONFLUENT_BALANCER_TOPIC_REPLICATION_FACTOR: 1
  KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
  KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1

主题"zipkin“被推送到kafka，因为我可以在我的spring应用程序中使用它。

Spring实现的application.properties中的zipkin设置如下所示。

spring.zipkin.baseUrl= localhost:9411
spring.zipkin.sender.type= kafka

我找不到任何关于我如何实际调试zipkin本身的东西。它在我的docker-compose中启动时没有错误。

Answer 1

实际上是我自己找到的。以防有人也遇到这种情况。

KAFKA.BOOTSTRAP.SERVERS: broker:19092

是无效的环境变量。它的风格需要是这样的：

KAFKA_BOOTSTRAP_SERVERS: broker:19092