Uploaded image for project: 'Debezium'
  1. Debezium
  2. DBZ-5249

KafkaDatabaseHistory without check database history topic create result caused UnknowTopicOrPartitionException

    XMLWordPrintable

Details

    • Bug
    • Resolution: Done
    • Major
    • 2.0.0.Beta1
    • 1.4.0.Final, 1.9.0.Final, 2.0.0.Alpha2
    • None
    • False
    • None
    • False

    Description

      Bug report

      In KafkaDatabaseHistory object without check database.history.kafka.topic create result, after snapshot will try to send data into this topic, then will cause UnknowTopicOrPartitionException. 

      What Debezium connector do you use and what version?

      Mysql Connector,  1.4.0.final

      What is the connector configuration?

      <Your answer>

      What is the captured database version and mode of depoyment?

      mysql 8.0.x  -> directly install in linux machine

      What behaviour do you expect?

      Connector can start success.

      What behaviour do you see?

       Database history topic '(name=xxx, numPartitions=1, replicationFactor=2, replicasAssignments=null, configs={cleanup.policy=delete, retention.ms=9223372036854775807, retention.bytes=-1})' created (io.debezium.relational.history.KafkaDatabaseHistory:502)

       

      But i got follow error info

       

      Do you see the same behaviour using the latest relesead Debezium version?

      no test, but i checked latest code, it's exist same issue i think.

      Do you have the connector logs, ideally from start till finish?

      (You might be asked later to provide DEBUG/TRACE level log)

      <Your answer>

      How to reproduce the issue using our tutorial deployment?

      Create many task, in my env, there are  800+ task.

      Feature request or enhancement

      check topic create result.

      Which use case/requirement will be addressed by the proposed feature?

      <Your answer>

      Implementation ideas (optional)

      check topic create result.

      Attachments

        Activity

          People

            Unassigned Unassigned
            doupengwei pengwei dou (Inactive)
            Votes:
            0 Vote for this issue
            Watchers:
            6 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: