回答情况：
提问时间：
问题标签：
我正在使用Kafka来实现多个微服务之间的通信。服务是用Python编写的，我使用Confluent库来处理Kafka。在某种程度上，我知道一些主题只是“结束”，这样我就可以自动清理它们。谢谢
浏览 0修改于2018-10-01得票数 1
想知道是否可以通过Admin API或其他api获取每个topic partition的滞后值？找到了这个，但是想要检查是否有直接的api可用呢？
浏览 3修改于2022-05-29得票数 1
回答已采纳
我是第一次接触confluent- kafka -python，我正在使用cp-all-in-one的docker-compose运行kafka。我创建了一个生产者，将数据生成到与offical tutorial相同的新主题中。 但是我在代码中找不到任何关于如何设置模式或到数据库的连接的信息。 我正在尝试将生成的数据保存到数据库中的表中，以便稍后可以将其加载到UI上。现在，每次我刷新Confluent Control Center主题页面时，似乎都会丢失数据。有没有关于这方面的教程？或者我没有正确地使用Kafka。
浏览 18修改于2020-12-22得票数 0
回答已采纳
我注意到传递调用Consumer.commit(msg=None)是一个有效的情况。至少它是在库的代码中单独处理的。我想知道这样做和使用"msg“参数的最后一条读消息调用Consumer.commit有什么区别。
浏览 2修改于2017-11-13得票数 2
回答已采纳
我在文档中找不到如何在使用confluent-kafka创建生产者时设置保留时间。(我想在python API中完成这项工作，而不是在命令行上。)
浏览 0修改于2018-09-27得票数 2
我们如何为confluent-kafka-python客户端做到这一点? 2)我们如何序列化protoBuf记录？
浏览 12修改于2018-09-26得票数 0
我需要使用confluent-kafka-python检索主题的最后N条消息。请帮帮忙。
浏览 17提问于2022-02-19得票数 2
回答已采纳
此日志可通过confluent-kafka-python producer client for confluent cloud中的debug=all配置获得。
浏览 21提问于2021-07-28得票数 1
挑战是，我在防火墙后面，没有代理来执行实际的pip install confluent-kafka-python
因此，我从github获得了合流-Kafka-python.zip，这样我就可以脱机安装并执行以下操作
浏览 0修改于2018-10-30得票数 0
回答已采纳
9092', auto_offset_reset='earliest', group_id='my-group')为了进行比较，我还尝试了confluent-kafka-python
浏览 1提问于2019-03-19得票数 0
我运行confluent producer示例如下：$ python producer.py localhost:9095 confluent
浏览 3修改于2018-09-26得票数 0
回答已采纳
2回答
我就是这样做的(Python，confluent-kafka-python)：
producer = Producer({'bootstrap.servers': 'localhost:9092'})
浏览 0修改于2020-02-02得票数 3
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号