当使用python套接字或telnet工作时，无法正确获取事件

作者: 哈哈哈哈
发布时间: 2024-01-25 05:04:00 (4月前)
转自：

2 条回复

0#
回复此人
夏花 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 发生这种情况的原因是因为您没有等待响应回来。默认情况下，Flume的netcat源将为每个事件发回“OK”消息。您可以在发送响应之前终止连接，这会导致处理其他消息失败（因为管道已从客户端断开）。 </p> <P> 要解决此问题，您需要对flume.conf进行以下更改： </p> <pre> <code> a1.sources.r1.ack-every-event=false </code> </pre> <P> 这消除了发送“OK”的要求，因此停止了故障。 </p> <P> 或者，您可以更改Python以等待每次在关闭连接之前发送“OK”消息。人为地，添加一个睡眠声明 <EM> 应该 </EM> 也解决了这个问题，尽管你要假设处理你的消息可能需要多长时间。通常很好，但可能有其他情况导致处理延迟。 </p> </DIV>

编辑

登录后才能参与评论