Ady Liu

Results 46 comments of Ady Liu

已经修复了此问题,临时发布了SNAPSHOT版本 https://github.com/adyliu/jeos#latest-snapshot-version 0.9.14版本 [http://repo1.maven.org/maven2/io/jafka/jeos/0.9.14/](http://repo1.maven.org/maven2/io/jafka/jeos/0.9.14/) 已经发布,预计未来几个小时会同步到全网。

可以了 已经同步了 > compile group: 'io.jafka', name: 'jeos', version: '0.9.14'

jafka 在windows x64下可以运行。 如果想包装成windows service服务,需要借助于 java wrapper service,参考官网 https://wrapper.tanukisoftware.com/doc/english/download.jsp#downloadNote4 > *4: 64-bit Windows versions of the Java Service Wrapper are not currently being made available in the Community Edition. x64下的wrapper...

consumer > broker:partition 那么就会有部分consumer无消息可消费,也就是没有offset

兼容0.7版本,非定期维护中。 single jar比较容易,但是不利于服务的启动和停止,自带java-wrapper-service管理服务较好。

每一个partition在相同的groupId下同时只能被一个consumer消费,如果这个consumer挂了,其它consumer自动接管(在此之前是待命状态)。如果增加partition,那么其它consumer也会接管继续消费。 保证任何消息可被消费,同时却不会冲突。 如果有多个groupId,那么每个groupId之间的consumer并不冲突,各自消费,当前一个partition会被每一组groupId的一个消费。有多少groupId,那么这个partition就会被消费多少次。

上面原来没有写清楚,我重新更正了下上面的回答。QQ:四一零九43200

事实上存储的是IP地址和端口,另外配置文件中可以指定应当是hostname还是ip地址。

配置下log4j.properties,在conf下有个样例。将日志输出都贴在下面。

java.nio.channels.UnresolvedAddressException --> ZK1:9092 无法解析ZK1的域名,解决方法(任选一种): 1. 绑定HOST (ZK1...) 2. 修改jafka/conf/server.properties中的hostname参数为本机的IP地址