linyuan123

jafka 消息的存储地址 问题

1

以wrapper启动的 jafka 消息的存储地址 在server.properties 设置了不起作用

consumer的问题

13

[hadoop@ZK1 bin]$ ./consumer-console.sh --zookeeper 192.168.1.97:2181,192.168.1.96:2181,192.168.1.98:2181 --topic ly --from-beginning log4j:WARN No appenders could be found for logger (com.sohu.jafka.consumer.ZookeeperConsumerConnector). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info....

关于 offsets 问题

1

消费者消费topic 中的一些消息 为什么zookeeper 中的offsets 是空的啊 ls /consumers [test_group1, test_group123, test_group, test_group2, test_group1235] ls /consumers/test_group [ids, owners, offsets] ls /consumers/test_group/offsets [test1234, ly1234567, test123456, lin123, test, demo123, ly123456, ssss, MJ] ls /consumers/test_group/offsets/lin123...