Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-10160

Kafka MM2 consumer configuration

    XMLWordPrintableJSON

    Details

      Description

      https://github.com/apache/kafka/blob/trunk/connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java#L51, according this producer/consumer level properties should be configured as e.g. somesource->sometarget.consumer.client.id, i try to set somesource->sometarget.consumer.auto.offset.reset=latest, but without success, consumer always tries to fetch earliest, not sure if bug or my misconfiguration, but then at least some update to docu would be useful

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                sbellapu sats
                Reporter:
                pipoth Pavol Ipoth
              • Votes:
                1 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: