我是第一次接触confluent- kafka -python,我正在使用cp-all-in-one的docker-compose运行kafka。我创建了一个生产者,将数据生成到与offical tutorial相同的新主题中。
但是我在代码中找不到任何关于如何设置模式或到数据库的连接的信息。
我正在尝试将生成的数据保存到数据库中的表中,以便稍后可以将其加载到UI上。现在,每次我刷新Confluent Control Center主题页面时,似乎都会丢失数据。有没有关于这方面的教程?或者我没有正确地使用Kafka。
发布于 2020-12-22 06:33:21
如果您使用AvroProducer发送数据,则会为您注册一个架构。
然而,这些链接中没有数据库,所以不清楚你在那里是什么意思。
如果"topic UI“指的是Confluent Control Center,那么查看消息就是documented here
https://stackoverflow.com/questions/65400148
复制相似问题