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

Double event publishing via NATS Jetstream sink

XMLWordPrintable

    • Critical

      Bug report

      What Debezium connector do you use and what version?

      Debezium Server 3.2.0, using the MySQL source connector (io.debezium.connector.mysql.MySqlConnector) and the NATS JetStream sink adapter

      What is the connector configuration?

      Standard configuration for the required fields.

      What is the captured database version and mode of deployment?

      MySQL 8.0.

      What behavior do you expect?

      No double events to NATS Jetstream

      What behavior do you see?

      Double events published to NATS Jetstream due to a recent fix under DBZ-9171

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

      Yes Debezium-server 3.2

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

      Not needed for this issue as its apparent from the code what caused it.

      How to reproduce the issue using our tutorial deployment?

      -Configure the mentioned source and sink connector config using Debezium server and update a db record to see the effect or refer to the snapshot events.

      Feature request or enhancement

      Bug

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

      Reliability with event sink to NATS Jetstream

      Implementation ideas (optional)

      remove the code on line# 204 of NatsJetStreamChangeConsumer.java 

      js.publish(subject, recordBytes);

              vjuranek@redhat.com Vojtech Juranek
              vpin54 Vpin K
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

                Created:
                Updated:
                Resolved: