You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Manikumar (JIRA)" <ji...@apache.org> on 2018/08/22 18:41:00 UTC

[jira] [Commented] (KAFKA-7314) MirrorMaker example in documentation does not work

    [ https://issues.apache.org/jira/browse/KAFKA-7314?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16589238#comment-16589238 ] 

Manikumar commented on KAFKA-7314:
----------------------------------

looks like both consumer/producer properties are pointing to same cluster.
Can you post your consumer.properties and the producer.properties values and mirror maker logs?

> MirrorMaker example in documentation does not work
> --------------------------------------------------
>
>                 Key: KAFKA-7314
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7314
>             Project: Kafka
>          Issue Type: Bug
>          Components: mirrormaker
>            Reporter: John Wilkinson
>            Priority: Critical
>
> Kafka MirrorMaker as described in the documentation [here|https://kafka.apache.org/documentation/#basic_ops_mirror_maker] does not work. Instead of pulling messages from the consumer-defined {{bootstrap.servers}} and pushing to the producer-defined {{bootstrap.servers}}, it consumes and producers on the same topic on the same host repeatedly.
> To replicate, set up two instances of kafka following [this|https://docs.confluent.io/current/installation/docker/docs/installation/recipes/single-node-client.html] guide. The schema registry and rest proxy are unnecessary. [Here|https://hub.docker.com/r/confluentinc/cp-kafka/] is the DockerHub page for the image.  The Kafka version is 2.0.0.
> Using those two kafka instances, go {{docker exec}} into one and set up the {{consumer.properties}} and the {{producer.properties}} following the MirrorMaker guide.
> Oddly, if you put in garbage unresolvable server addresses in the config, there will be an error, despite the configs not getting used.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)