Details
-
Bug
-
Resolution: Not a Bug
-
Major
-
None
-
1.6.0.Final
-
None
-
False
-
False
-
Undefined
-
Description
While running debezium on SQL Server Database with Docker it crashes to Deserialize after connector restart. The only way to make it work again is to create the same SQL Server Connector with a new Connector Name.
docker-compose:
# Debezium Connect connect: container_name: debeziumconnect image: debezium/connect:1.6 ports: - 8083:8083 links: - zookeeper - kafka - app - schema-registry depends_on: - app - schema-registry - kafka environment: - GROUP_ID=1 - CONFIG_STORAGE_TOPIC=my_connect_configs - OFFSET_STORAGE_TOPIC=my_connect_offsets - STATUS_STORAGE_TOPIC=my_source_connect_statuses - BOOTSTRAP_SERVERS=kafka:29092 - CONNECT_KEY_CONVERTER=io.confluent.connect.avro.AvroConverter - CONNECT_VALUE_CONVERTER=io.confluent.connect.avro.AvroConverter - CONNECT_KEY_CONVERTER_SCHEMA_REGISTRY_URL=http://schema-registry:8081 - CONNECT_VALUE_CONVERTER_SCHEMA_REGISTRY_URL=http://schema-registry:8081 - CONNECT_KEY_CONVERTER_SCHEMAS_ENABLE=true - CONNECT_VALUE_CONVERTER_SCHEMAS_ENABLE=true networks: - debezium-compose-network
SQL Server Connector:
curl -X POST -H "Content-Type: application/json" --data ' { "name": "sqlserver-connector-clients", "config": { "connector.class": "io.debezium.connector.sqlserver.SqlServerConnector", "database.hostname": "app", "database.port": "1433", "database.user": "app", "database.password": "somePwdGoesHere!", "database.dbname": "app", "database.server.name": "app", "table.include.list": "dbo.clients", "database.history.kafka.bootstrap.servers": "kafka:9092", "database.history.kafka.topic": "app.dbo.clients", "key.converter": "io.confluent.connect.avro.AvroConverter", "key.converter.schema.registry.url": "http://schema-registry:8081", "value.converter": "io.confluent.connect.avro.AvroConverter", "value.converter.schema.registry.url": "http://schema-registry:8081" } }' http://localhost:8083/connectors -w "\n"
Error on Debezium Server Restart:
ERROR || Error while deserializing history record 'ConsumerRecord(