我是 confluent-kafka-python 的新手，我正在使用cp-all-in-one 中的docker-compose 运行 kafka 。我创建了一个生产者，为一个与官方教程相同的新主题生成数据。
但我找不到有关如何在代码中设置架构或与数据库的连接的任何信息。
我正在尝试将生成的数据保存到数据库中的表中，以便稍后我可以将其加载到 UI 上。现在每次我刷新 Confluent Control Center 主题页面时，似乎我都会丢失数据。有这方面的教程吗？还是我错误地使用了 Kafka。