使用 confluent-kafka-python 设置主题模式
Using confluent-kafka-python to setup schema for topic
我是 confluent-kafka-python 我是 运行 kafka 使用 docker-compose 来自 cp-all-in-one。
我创建了一个生产者，为与 offical tutorial.
相同的新主题生产数据
但我找不到任何有关如何在代码中设置模式或连接到数据库的信息。
我正在尝试将生成的数据保存到数据库中的 table 中，以便稍后我可以将其加载到 UI 中。
现在每次刷新 Confluent Control Center 主题页面时，我似乎都丢失了数据。有这方面的教程吗？还是我用错了 Kafka。
如果您使用 AvroProducer 发送数据，系统会为您注册一个架构。
不过，这些链接中没有数据库，因此不清楚您的意思。
如果通过“主题 UI”，您指的是 Confluent Control Center，查看消息是 documented here
我是 confluent-kafka-python 我是 运行 kafka 使用 docker-compose 来自 cp-all-in-one。 我创建了一个生产者，为与 offical tutorial.
相同的新主题生产数据但我找不到任何有关如何在代码中设置模式或连接到数据库的信息。
我正在尝试将生成的数据保存到数据库中的 table 中，以便稍后我可以将其加载到 UI 中。 现在每次刷新 Confluent Control Center 主题页面时，我似乎都丢失了数据。有这方面的教程吗？还是我用错了 Kafka。
如果您使用 AvroProducer 发送数据，系统会为您注册一个架构。
不过，这些链接中没有数据库，因此不清楚您的意思。
如果通过“主题 UI”，您指的是 Confluent Control Center，查看消息是 documented here