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

Debezium signalling custom channel doesn't work

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Not a Bug
    • Icon: Blocker Blocker
    • None
    • 2.4.2.Final
    • None
    • False
    • None
    • False
    • Important

      Hi

      We are using Debezium connector for mysql version 2.4.2

      We implemented a custom signal channel in Java which consume the signal messages from a Kafka topic,
      However we are unable to get it to work.
      We copied the jar to the debezium connector directory (we also tried copy the jar to the same directory where the custom converter jar is located) and added "signal.enabled.channels" config (with the name we gave to the reader as a value) to the connector configuration as explained here:
      https://debezium.io/blog/2023/07/10/custom-http-signaling-notification/

      In order to check it we added logs to the init method and to the reader constructor but we are not seeing those logs or any sign that the snapshot was executed after we produced a proper signal message to the topic.

       

      For testing purposes we are raising an exception from the init method and reader constructor and we don't see it in the logs.
      Attaching the connector logs (also with debug)

      What are we missing?

      Thanks for assisting
      Sefi

      Dev tech lead,
      SKAI

              Unassigned Unassigned
              sefi.zer Sefi Zer (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

                Created:
                Updated:
                Resolved: