Skip to content

zeelos/kafka-mirrormaker-docker

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

5 Commits
 
 
 
 
 
 
 
 

Repository files navigation

kafka-mirrormaker-docker

Docker Pulls

A Docker image that executes a kafka MirrorMaker process. It follows the Dockerfile template creation as specified by Confluent's own images.

The image follows Confluent platform versioning so that is easier for you to match your own Kafka installation, that is you can use either tag 4.1.1 or 5.0.0 to match your specific versions.

An example usage in a docker-compose.yml file can be like the following. Note the usage of MIRRORMAKER_ prefix (for MirrorMaker specific configuration), CONSUMER_ (for consumer configuration) and PRODUCER_ (for producer configuration).

  kafka-mirrormaker:
    image: zeelos/kafka-mirrormaker:4.1.1
    environment:
      - MIRRORMAKER_WHITE_LIST=^server1_((?!req).)*$$
      - MIRRORMAKER_ABORT_ON_SEND_FAILURE=true
      - MIRRORMAKER_OFFSET_COMMIT_INTERVAL=60000
      - MIRRORMAKER_NUM_STREAMS=1
      - MIRRORMAKER_CONSUMER_REBALANCE_LISTENER=org.mypackage.MyListener
      - MIRRORMAKER_CONSUMER_REBALANCE_LISTENER_ARGS=arg1,arg2
      - MIRRORMAKER_MESSAGE_HANDLER=org.mypackage.MyHandler
      - MIRRORMAKER_MESSAGE_HANDLER_ARGS=arg1,arg2
      - CONSUMER_BOOTSTRAP_SERVERS=kafka-source-server:9092
      - CONSUMER_GROUP_ID=MirrorMaker
      - CONSUMER_AUTO_OFFSET_RESET=latest
      - PRODUCER_BOOTSTRAP_SERVERS=kafka-destination-server:9092
    ...

NOTE: Make sure you correctly escape your regular expression for 'MIRRORMAKER_WHITE_LIST' configuration so that no to conflict with docker during expansion. In the example above, we used a double dollar sign ($$) to escape the single dollar ($).

About

A Docker image that executes the Apache MirrorMaker process.

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published