You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Using KAFKA_LISTENERS=PLAINTEXT://172.17.0.229:9092 and KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://172.17.0.229:9092
Using KAFKA_BROKER=172.17.0.229:9092
Contents of topic ob7:
5 {"id":5}
after post. the log seems connect target database successful and fetched the schema already.
ache.kafka.clients.consumer.internals.ConsumerCoordinator:307)
[2024-07-03 10:16:36,923] INFO [connect-mysql-sink|task-0] [Consumer clientId=connector-consumer-connect-mysql-sink-0, groupId=connect-connect-mysql-sink] Adding newly assigned partitions: ob7-0 (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:319)
[2024-07-03 10:16:36,934] INFO [connect-mysql-sink|task-0] [Consumer clientId=connector-consumer-connect-mysql-sink-0, groupId=connect-connect-mysql-sink] Setting offset for partition ob7-0 to the committed offset FetchPosition{offset=1, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[172.17.0.229:9092 (id: 1 rack: null)], epoch=0}} (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator:975)
[2024-07-03 10:17:00,651] INFO [connect-mysql-sink|task-0] JdbcDbWriter Connected (io.confluent.connect.jdbc.sink.JdbcDbWriter:56)
[2024-07-03 10:17:00,721] INFO [connect-mysql-sink|task-0] Checking MySql dialect for existence of TABLE "es4" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect:595)
[2024-07-03 10:17:00,778] INFO [connect-mysql-sink|task-0] Using MySql dialect TABLE "es4" present (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect:603)
[2024-07-03 10:17:00,824] INFO [connect-mysql-sink|task-0] Checking MySql dialect for type of TABLE "es4" (io.confluent.connect.jdbc.dialect.GenericDatabaseDialect:889)
[2024-07-03 10:17:00,831] INFO [connect-mysql-sink|task-0] Setting metadata for table "es4" to Table{name='"es4"', type=TABLE columns=[Column{'id', isPrimaryKey=true, allowsNull=false, sqlType=INT}]} (io.confluent.connect.jdbc.util.TableDefinitions:64)
but there is no data in the target table , no more logs until 4 minutes later .
[2024-07-03 10:21:26,117] INFO [AdminClient clientId=connect-cluster--shared-admin] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:977)
[2024-07-03 10:25:26,827] INFO [Producer clientId=connect-cluster--offsets] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:977)
[2024-07-03 10:25:27,182] INFO [Consumer clientId=connect-cluster--offsets, groupId=connect-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:977)
[2024-07-03 10:25:27,671] INFO [Producer clientId=connect-cluster--statuses] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:977)
[2024-07-03 10:25:27,786] INFO [Consumer clientId=connect-cluster--statuses, groupId=connect-cluster] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:977)
[2024-07-03 10:25:28,460] INFO [Producer clientId=connect-cluster--configs] Node -1 disconnected. (org.apache.kafka.clients.NetworkClient:977)
The text was updated successfully, but these errors were encountered:
sunzhaoyang
changed the title
jdbc sink didn't write data to target table and no errrors
jdbc sink doesn't write data to target table and no errrors
Jul 4, 2024
Environment
kafka:2.4
zookeeper:2.4
confluentinc-kafka-connect-jdbc-10.7.6
Test
producer
send simple message :
5:{"id":5}
watcher
start a watcher and can see this message
docker run -it --net host --rm --name watcher -e ZOOKEEPER_CONNECT=172.17.0.229:2181 -e KAFKA_BROKER=172.17.0.229:9092 -e KAFKA_LISTENERS=PLAINTEXT://172.17.0.229:9092 -e KAFKA_ADVERTISED_LISTENERS=PLAIEXT://172.17.0.229:9092 quay.io/debezium/kafka:2.4 watch-topic -a -k ob7
sink jdbc
config
after post. the log seems connect target database successful and fetched the schema already.
but there is no data in the target table , no more logs until 4 minutes later .
The text was updated successfully, but these errors were encountered: