Debezium server with sql server

116 views
Skip to first unread message

pantawat promchart

unread,
Feb 15, 2024, 4:27:17 AM2/15/24
to debezium
Hi
I'm use Debezium server docker version to connect source with sql server and sink with RabbitMQ but when I config in application.properties 
it require debezium.source.topic.prefix so I try to fill randon name 
but still require schema.history.internal.kafka.topic and schema.history.internal.kafka.bootstrap.servers.

this my config in  application.properties 

debezium.source.connector.class=io.debezium.connector.sqlserver.SqlServerConnector
debezium.source.offset.storage.file.filename=data/offsets.dat

debezium.source.database.hostname=192.168.1.45
debezium.source.database.port=1433
debezium.source.database.user=adminsqldevserver
debezium.source.database.password=5641651616
debezium.source.database.names=Neo4node
debezium.source.database.encrypt=false
debezium.source.table.include.list=shipments

debezium.sink.type=rabbitmq
debezium.sink.rabbitmq.connection.host=my-rabbitmq
debezium.sink.rabbitmq.connection.port=5672
debezium.sink.rabbitmq.connection.username=guest
debezium.sink.rabbitmq.connection.password=guest
debezium.sink.rabbitmq.connection.virtual.host=/
debezium.sink.rabbitmq.exchange=debezium.sqlserver

i think Debezium server is not neccessory to use kafka right? so how i can solve
help me pls

jiri.p...@gmail.com

unread,
Feb 15, 2024, 4:30:14 AM2/15/24
to debezium
Hi,


Just don't forget to add debezium.source prefix.

Jiri

Reply all
Reply to author
Forward
0 new messages