Python中文
首页
教程
问答
标签
搜索
登录
注册
不接收信息与融合卡夫卡简单生产者/消费者的例子?
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我使用<code>confluent-kafka-0.9.2</code>(主分支)python绑定运行<code>kafka_2.11-0.10.1.1</code>,它使用<code>librdkafka-0.9.2</code>。我的机器运行ubuntu-16.04x86_64。我在端口<code>zookeeper-3.4.8-1</code>上运行<code>zookeeper-3.4.8-1</code>。我运行confluent<strong>producer</strong>示例如下:</p> <pre><code>$ cd confluent-kafka-python/examples $ python producer.py localhost:9095 confluent-01 first message 2nd msg </code></pre> <p>以及<strong>消费者</strong>:</p> ^{pr2}$ <p>所有东西都在我的机器上本地运行,它不运行任何防火墙。在</p> <p><strong>备注</strong>:</p> <ul> <li>主题已在Zookeeper上成功创建</li> <li>代理已成功接收生产者消息:</li> <li>使用者设置如下conf<code>{'bootstrap.servers': broker, 'group.id': group, 'session.timeout.ms': 6000, 'default.topic.config': {'auto.offset.reset': 'smallest'}, 'api.version.request': True }</code></li> <li>在一开始,<code>producer/consumer</code>可以很好地工作一段时间,直到我得到<code>Receive failed: Disconnected</code>的制作人。行使:</li> </ul> <hr/> <pre><code>$ python producer.py localhost:9095 confluent-02 asd % Message delivered to confluent-02 [0] 1234123 890890 % Message delivered to confluent-02 [0] %3|1485791262.420|FAIL|rdkafka#producer-1| [thrd:obscura.ax.example.com:9095/3]: obscura.ax.example.com:9095/3: Receive failed: Disconnected </code></pre> <p><strong>问题</strong>:过了一段时间,我对消费者没有任何看法</p> <p>问题:</p> <ol> <li>我做错什么了?在</li> <li><strong>如何验证已在代理端接收到生产者消息?</strong> 在代理端正确地接收到生产者消息。在</li> <li><strong>如何调试用户端?</strong> 我将<code>'debug': "cgrp, topic, fetch"</code>添加到consumer conf中。在哪里可以读取日志?在</li> </ol>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>我有两个建议:</p> <p>1)尝试在consumer命令中添加从头到尾的选项</p> <p>2)代理的默认端口是9092,因此请检查要使用的正确端口</p> <p>希望这有帮助。在</p>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
如何在python中从数据帧列中删除分类值?
8 回答
如何在python中从数据帧列表中删除引号
1 回答
如何在python中从数据帧创建列表
10 回答
如何在Python中从数据帧创建嵌套的JSON
3 回答
如何在Python中从数据帧显示wordcloud
9 回答
如何在Python中从数据帧的时间戳中删除字符
4 回答
如何在Python中从数据帧绘制简单绘图?
4 回答
如何在python中从数据帧行提取具有特定长度的范围?
10 回答
如何在python中从数据帧设置dict中的值
8 回答
如何在Python中从数据库中获得一个结果
6 回答
如何在python中从数据框中绘制分类条形图
9 回答
如何在Python中从数据框中选择特定细节?
8 回答
如何在python中从数据集中删除unicode
8 回答
如何在python中从数据集中删除某些数值?
4 回答
如何在python中从数据集中选择行
2 回答
如何在Python中从数组中删除元素
4 回答
如何在python中从数组中删除单个倒逗号?
2 回答
如何在python中从数组中删除对象?
9 回答
如何在python中从数组中删除引号
3 回答
如何在python中从数组中删除所有最小值
7 回答