?????? kafka configure problem

2017-12-25 Thread G~D~Lunatic
in controller.log.-XX topics not in preferred replica Map() (kafka.controller.KafkaController) is this normal? -- -- ??: "Ted Yu";; : 2017??12??26??(??) 10:19 ??: "users"; : Re: kafka configure problem When you issue

Re: Consumer group describe issue

2017-12-25 Thread sahil aggarwal
Attached the patch. If someone can review it will be very helpfull. Thanks, sahil On 23 December 2017 at 13:11, sahil aggarwal wrote: > my bad its consumer.endOffsets in ConsumerGroupCommand.scala. > > https://github.com/apache/kafka/blob/ef97ed7ee5cb883a30245ea4f77ef9 > 9d4db15373/core/src/

Re: kafka configure problem

2017-12-25 Thread Ted Yu
When you issue 'ps aux' on the node where the broker is running, you would see command ending with 'kafka.Kafka server.properties' In that command line, you can find log dir by checking -Dkafka.logs.dir argument. In that log dir, you would see (controller.log and) server.log Cheers On Mon, Dec

?????? kafka configure problem

2017-12-25 Thread G~D~Lunatic
thank you , what's the file path of broker log. i have no idea about checking log -- -- ??: "Ted Yu";; : 2017??12??26??(??) 9:50 ??: "users"; : Re: kafka configure problem Was broker running on 52.194 encountering some e

Re: kafka configure problem

2017-12-25 Thread Ted Yu
Was broker running on 52.194 encountering some error ? Can you check broker log on 52.194 ? Thanks On Mon, Dec 25, 2017 at 5:03 PM, G~D~Lunatic <747620...@qq.com> wrote: > i‘ m a beginner of kafka. i usde kafka_2.11-0.9.0.1. my kafka built in > two virtual machine which ip are 52.193 and 52.1

kafka configure problem

2017-12-25 Thread G~D~Lunatic
i?? m a beginner of kafka. i usde kafka_2.11-0.9.0.1. my kafka built in two virtual machine which ip are 52.193 and 52.194 when i use commonds both in 52.193./kafka-console-producer.sh --broker-list 192.168.52.193:9092 --topic shuaige and ./kafka-console-consumer.sh --zookeeper 192.168.52.195:

kafka configure problem

2017-12-25 Thread 刘闯
i‘ m a beginner of kafka. i usde kafka_2.11-0.9.0.1. my kafka built in two virtual machinewhich ip are 52.193 and 52.194 when i use commonds both in 52.193 ./kafka-console-producer.sh --broker-list 192.168.52.193:9092 --topic shuaige and ./kafka-console-consumer.sh --zookeeper 192.168.52.195:21