Results 88 comments of childe

没有 Leader,好像本来就不能消费。

备注一下,老的 healer 版本, 不会处理 no-leader 这种错误,新的会做 rejoin,直到 leader 恢复才能消息。

UDP 的已经添加了。 配置如下: ``` inputs: - UDP: address: 127.0.0.1:10000 add_remote_addr: remote outputs: - Stdout: {} ```

好的! 多谢~ 我也看一下这个怎么获取版本和提示

不能。确定是这种格式?看着不太通用,有点难搞。

之前尝试过 Avro, 用的第三方的库, 好像是 Facebook 的. 但我们公司 Java 编码后的数据, 解析失败, 简单的可以, 但复杂的不行. 还没有深入去查原因.

LZ4的问题, 我在 https://github.com/childe/gohangout/issues/15 提到过. 根源是Kafka Java Client自己对 Lz4 编码的时候有问题, 导致别的库没法解码. 可以对 Go 的 Lz4的库的源码做修改后支持.

看一下你的 IPIP 的配置 @yeyuqiu

谢谢。 PR 里面我提了一些 Review,我们一起看下吧。