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

Improve resume change stream error message

    XMLWordPrintableJSON

Details

    • Icon: Improvement Improvement
    • Resolution: Works as Designed
    • Icon: Major - P3 Major - P3
    • None
    • None
    • None
    • None

    Description

      In https://jira.mongodb.org/browse/KAFKA-91 added error message.
      I think it's not completely correct.
      https://github.com/mongodb/mongo-kafka/blob/master/src/main/java/com/mongodb/kafka/connect/source/MongoSourceTask.java#L300-L301

      Kafka Connect uses its own mechanism, not kafka consumer group to store offsets for source connectors. So, as far as I understand there is no way to use kafka-consumer-groups.sh to reset offsets.

      If I'm wrong about using kafka-consumer-groups.sh, please make the message more explicit.

      Could be helpful:
      https://rmoff.net/2019/08/15/reset-kafka-connect-source-connector-offsets/

      Attachments

        Activity

          People

            ross@mongodb.com Ross Lawley
            andreworty@gmail.com Andrey B
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: