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

Ad-hoc snapshot does not effect sometime after sending a signal to Kafka signal table

    XMLWordPrintable

Details

    • Bug
    • Resolution: Unresolved
    • Major
    • under-triaging
    • 1.7.0.Final
    • mysql-connector
    • None
    • False
    • False

    Description

      Ad-hoc snapshot take no effect after send a signal to kafka signal table, and without any error log. 

       

      DBZ version : 1.7.0-FINAL

      Connector config :

      {
        "connector.class": "io.debezium.connector.mysql.MySqlConnector",
        "tasks.max": "1",
        "database.hostname": "sr-test-mysql-school-master-1.xxx.com",
        "database.port": "3306",
        "database.user": "xxx",
        "database.password": "xxx",
        "database.connectionTimeZone": "Asia/Shanghai",
        "database.include.list": "seewo_school,seewo_school_teaching_plan,seewo_time_capsule",
        "database.server.name": "debezium.sync.sr_test_mysql_school_master_1_xxx_3306",
        "database.history.kafka.bootstrap.servers": "xxx",
        "database.history.kafka.topic": "debezium.sync.dbhistory.sr_test_mysql_school_master_1_xxx_3306",
        "table.include.list": "seewo_school.school,seewo_school_teaching_plan.t_teacher_teaching_plan_info,seewo_time_capsule.t_time_capsule",
        "snapshot.locking.mode": "minimal",
        "snapshot.mode": "initial",
        "read.only": "true",
        "topic.creation.enable": "true",
        "topic.creation.default.partitions": "1",
        "topic.creation.default.replication.factor": "3",
        "topic.creation.default.cleanup.policy": "compact",
        "topic.creation.default.compression.type": "snappy",
        "topic.creation.default.min.compaction.lag.ms": "86400000",
        "signal.kafka.topic": "debezium.sync.sr_test_mysql_school_master_1_xxx_3306-signal",
        "signal.kafka.bootstrap.servers": "xxx",
        "decimal.handling.mode": "double",
        "time.precision.mode": "connect",
        "binary.handling.mode": "bytes",
        "tombstones.on.delete": "true",
        "include.schema.changes": "true",
        "max.queue.size": "8192",
        "max.batch.size": "2048",
        "producer.override.acks": 1,
        "producer.override.compression.type": "snappy",
        "converters": "customTimestampConverter",
        "customTimestampConverter.type": "io.debezium.converter.TimestampConverter",
        "customTimestampConverter.type.namelist": "year,date,time,datetime,timestamp",
        "value.converter": "org.apache.kafka.connect.json.JsonConverter",
        "key.converter": "org.apache.kafka.connect.json.JsonConverter"
      } 

       

       

      Attachments

        Activity

          People

            Unassigned Unassigned
            aib628 cc vmaster
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: