问题描述
我是 confluent-kafka-python 的新手,我正在使用 cp-all-in-one 的 docker-compose 运行 kafka。 我创建了一个生产者,为与 offical tutorial 相同的新主题生产数据。
但我在代码中找不到有关如何设置架构或与数据库的连接的任何信息。
我正在尝试将生成的数据保存到数据库中的表中,以便稍后我可以在 UI 上加载它。 现在每次刷新 Confluent 控制中心主题页面时,我似乎都丢失了数据。有这方面的教程吗?还是我错误地使用了Kafka。
解决方法
如果您使用 AvroProducer
发送数据,则会为您注册一个架构。
不过,这些链接中没有数据库,所以不清楚你在那里的意思。
如果“主题 UI”是指 Confluent 控制中心,则查看消息为 documented here