Skip to content

miguecoll/kafka-mirror-maker

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

7 Commits
 
 
 
 
 
 
 
 

Repository files navigation

kafka-mirror-maker

This is a simple kafka mirror-maker using a default java:openjdk-8-jre source and adding the kafka version specified on Dockerfile.

The Build process download the tgz file from the defined mirror and install it simply by untar and creating a symlink to /opt/kafka

run.sh script require the following variables:

  • DESTINATION=xxx.xxx.com:9092
  • SOURCE=xxx.xxx.com:9092
  • GROUPID="xxxx"
  • WHITELIST="xxxx"

NOTE: $WHITELIST is bypassed to kafka mirror-maker. Therfore follow the recomendations on the official documentation. Kafka Documentation

Note that we specify the list of topics with the --whitelist option. This option allows any regular expression using Java-style regular expressions. So you could mirror two topics named A and B using --whitelist 'A|B'. Or you could mirror all topics using --whitelist '*'. Make sure to quote any regular expression to ensure the shell doesn't try to expand it as a file path. For convenience we allow the use of ',' instead of '|' to specify a list of topics.

the execution will create a /etc/mirror-maker/consumer.properties and /etc/mirror-maker/producer.properties and launch mirror-maker using:

/opt/kafka/bin/kafka-mirror-maker.sh --whitelist ${WHITELIST} --abort.on.send.failure true --new.consumer --producer.config /etc/mirror-maker/producer.properties --consumer.config /etc/mirror-maker/consumer.properties

Building the Docker

Once you are in the Dockerfile directory execute:

docker build . -t mirror-maker 

Running the Docker

docker run -it -e DESTINATION=xxx.xxx.com:9092 -e SOURCE=xxx.xxx.com:9092 -e GROUPID=_mirror_maker -e WHITELIST=<TOPIC NAME> mirror-maker:latest

Releases

No releases published

Packages

No packages published

Languages