An OpenJDK 11 & Kafka 2.3 upgraded version of ambuds/mirror-maker image . Also, performance and durability improvements has been made by default.
Docker image: https://hub.docker.com/r/veysiertekin/kafka-mirror-maker/
git clone https://github.com/veysiertekin/kafka-mirror-maker.git
cd kafka-mirror-maker
docker build -t mirror-maker:latest .
Note: Docker is expected to be installed where you run the build
Variable Name | Description | Defaults |
---|---|---|
DESTINATION | bootstrap.servers for the Destination Kafka Cluster | localhost:9092 |
SOURCE | bootstrap.servers for the Source Kafka Cluster | localhost:9092 |
WHITELIST | Topics to mirror | * |
GROUPID | Consumer group id for Kafka consumer | _mirror_maker |
docker run -it -e DESTINATION=xxx.xxx.com:9092 -e SOURCE=xxx.xxx.com:9092 -e WHITELIST=<TOPIC NAME> mirror-maker:latest
To deploy this image in Kubernetes here's the template.
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: mirror-maker
spec:
replicas: 1
template:
metadata:
labels:
name: mirror-maker
spec:
containers:
- name: mirror-maker
image: veysiertekin/kafka-mirror-maker
imagePullPolicy: Always
env:
- name: "WHITELIST"
value: "*"
- name: "DESTINATION"
value: "localhost:9092"
- name: "SOURCE"
value: "localhost:9092"
Apache 2.0