我是新的汇合Kafkapython我运行Kafka使用docker compose从cp全合一。我创建了一个生产者，为一个新的主题生成数据，这个主题与官方教程相同。
但是我在代码中找不到关于如何设置模式或数据库连接的任何信息。
我正在尝试将生成的数据保存到数据库中的一个表中，以便以后可以将其加载到ui上。现在，每次刷新confluent control center主题页时，似乎都会丢失数据。有这方面的教程吗？还是我用Kafka不正确。