Debezium Reinitialize

General
1

Hello!
I work with yugabyte, and want to reinitialize events that was sent early to kafka. I try to do it with

curl -X POST http://localhost:8083/connectors/ 
-H “Accept: application/json” 
-H “Content-Type: application/json” 
-d '{
“name”: “ybconnector2”,
“config”: {
“connector.class”: “io.debezium.connector.yugabytedb.YugabyteDBgRPCConnector”,
“database.hostname”: “<tserser_address>”,
“database.port”: “5433”,
“database.master.addresses”: “<master_addresses>”,
“database.user”: “user”,
“database.password”: “111”,
“database.dbname”: “master”,
“database.server.name”: “dbaas-infrastructure-tester2.yugabytedb”,
“table.include.list”: “public.items2,public.debezium_signal_3”,
“database.streamid”: “stream_id”,
“snapshot.mode”: “initial”, "topic.creation.default.replication.factor": "1",
  "topic.creation.default.partitions": "1",
  "key.converter": "org.apache.kafka.connect.storage.StringConverter",
  "value.converter": "org.apache.kafka.connect.json.JsonConverter",
  "value.converter.schemas.enable": "false",
  "decimal.handling.mode": "string", "signal.data.collection": "public.debezium_signal_3","signal.enabled.channels":"source" }}'

Where I inserted value in table public.debezium_signal_3 like “resync-items2-final-attempt-3 | execute-snapshot | {“data-collections”: [“public.items2”], “type”:“incremental”}“
but nothing didn’t happen.
How can I sent events again?

2

Hello @pugprogram , from your config it seems like you are trying to use the gRPC connector to take an incremental snapshot. Is my understanding correct?

want to reinitialize events that was sent early to kafka

Have you created a new stream_id or are you using an existing one?

3

Hello, yes, you understand correctly
I use existing stream_id.
I understand that I can make resnapshot if I create new stream but I need restream only one table.

4

Currently we do not support incremental snapshot with gRPC connector.

Instead you can create a new stream and deploy a new connector instance which polls only on the table public.debezium_signal_3