Java consumer-group & consumer-producer repository by @obsidiandynamics. Model Context Protocol (MCP) server & tools with 6.2k stars.
docker pull obsidiandynamics/kafdrop
docker run -d --name kafdrop -p 9000:9000 --restart always obsidiandynamics/kafdrop
podman run -d --name kafdrop -p 9000:9000 --restart always obsidiandynamics/kafdrop
skopeo inspect docker://docker.io/obsidiandynamics/kafdrop:latest
oras pull obsidiandynamics/kafdrop
docker compose up -d
version: "2"
services:
kafdrop:
image: obsidiandynamics/kafdrop
restart: "no"
ports:
- "9000:9000"
environment:
KAFKA_BROKERCONNECT: "kafka:29092"
depends_on:
- "kafka"
kafka:
image: obsidiandynamics/kafka
restart: "no"
ports:
- "2181:2181"
- "9092:9092"
environment:
KAFKA_LISTENERS: "INTERNAL://:29092,EXTERNAL://:9092"
KAFKA_ADVERTISED_LISTENERS: "INTERNAL://kafka:29092,EXTERNAL://localhost:9092"
KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: "INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT"
KAFKA_INTER_BROKER_LISTENER_NAME: "INTERNAL"
KAFKA_ZOOKEEPER_SESSION_TIMEOUT: "6000"
KAFKA_RESTART_ATTEMPTS: "10"
KAFKA_RESTART_DELAY: "5"
ZOOKEEPER_AUTOPURGE_PURGE_INTERVAL: "0"