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问题
plt.savefig不会覆盖现有文件
9 回答
plt.savefig不保存图像
2 回答
plt.savefig在jupyter笔记本中不起作用
5 回答
plt.savefig在从另一个fi调用时停止工作
6 回答
plt.savefig在调用plt.show之前保存空数字
9 回答
plt.save不创建png文件
3 回答
plt.scatter overlay分类数据帧列
6 回答
Plt.Scatter:如何添加title、xlabel和ylab
7 回答
plt.scatter()绘图与Matplotlib中的plt.plot()绘图类似
8 回答
plt.scatter错误'NoneType'对象在成功运行后没有属性'sqrt'
5 回答
plt.set_title()中的标题字符串有误
3 回答
plt.show()
8 回答
plt.show()不在Jupyter笔记本上渲染任何内容
10 回答
plt.show()不打印plt.plot only plt.scatter
4 回答
plt.show()不显示三维散射图像
6 回答
plt.show()不显示任何内容
7 回答
plt.show()不显示数据,而是保留它供下一个图表使用(spyder)
8 回答
plt.show()使终端挂起
4 回答
plt.show()无法使用此代码
5 回答
plt.show()没有打开新的图形风
10 回答