KAFKA_INTER_BROKER_LISTENER_NAME: DOCKER
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: DOCKER:PLAINTEXT, LOCALHOST:PLAINTEXT
KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+ KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
+ KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
KAFKA_AUTO_CREATE_TOPICS_ENABLE: "false"
ports:
- 9092:9082
- kafka
splitter:
- image: juplo/wordcount--splitter:1.0.0
+ image: juplo/wordcount--splitter:1.0.0-spring-integration
labels:
- "traefik.enable=true"
- "traefik.http.routers.splitter.rule=Host(`splitter.localhost`)"
- "traefik.http.routers.splitter.entrypoints=web"
environment:
- juplo.wordcount.splitter.bootstrap-server: kafka:9092
+ spring.kafka.bootstrap-servers: kafka:9092
depends_on:
- kafka