带redis的Debezium服务器
带redis的Debezium服务器
提问于 2022-08-15 11:44:22
我是Debezium的新手，我希望我的Debezium Server流将事件从Postogres更改为Redis (流)。
在日志中，它似乎读取了数据库中的更改，但没有在redis中发布任何内容。
我的配置application.properties
debezium.sink.type=redis
debezium.sink.redis.address=0.0.0.0:6379
debezium.sink.redis.batch.size=10
debezium.source.connector.class=io.debezium.connector.postgresql.PostgresConnector
debezium.source.offset.storage.file.filename=data/offsets.dat
debezium.source.offset.flush.interval.ms=0
debezium.source.database.hostname=0.0.0.0
debezium.source.database.port=5432
debezium.source.database.user=postgres
debezium.source.database.password=postgres
debezium.source.database.dbname=postgres
debezium.source.database.server.name=postgres
debezium.source.table.include.list=inventory
quarkus.log.console.json=trueDebezium服务器日志：
Starting PostgresConnectorTask with configuration:
connector.class = io.debezium.connector.postgresql.PostgresConnector
debezium.sink.redis.batch.size = 10
database.user = postgres
database.dbname = postgres
debezium.sink.type = redis
offset.storage = org.apache.kafka.connect.storage.FileOffsetBackingStore
debezium.sink.redis.address = 0.0.0.0:6379
database.server.name = postgres
offset.flush.timeout.ms = 5000
database.port = 5432
offset.flush.interval.ms = 0
internal.key.converter = org.apache.kafka.connect.json.JsonConverter
offset.storage.file.filename = data/offsets.dat
database.hostname = 0.0.0.0
database.password = ********
name = redis
internal.value.converter = org.apache.kafka.connect.json.JsonConverter
table.include.list = inventory
value.converter = org.apache.kafka.connect.json.JsonConverter
key.converter = org.apache.kafka.connect.json.JsonConverter
2022-08-15 12:37:06,909 INFO [io.quarkus] (main) debezium-server-dist 1.9.5.Final on 0.0.0:8080因此，我的问题是:我是否必须提到redis数据库的名称，以及我的配置是否正确？
谢谢
回答 1
Stack Overflow用户
发布于 2022-08-15 14:26:59
有什么错误吗？您能以调试模式运行并共享日志吗？配置看起来没问题
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/73360557
复制相关文章
相似问题
腾讯云开发者
