i have charset question about kafka

2016-10-18 Thread /kun????????
i hava test my kafka programe using kafka-console-producer.sh and kafka-console-consumer.sh. setp1 : [oracle@bd02 bin]$ ./kafka-console-producer.sh --broker-list 133.224.217.175:9092 --topic oggtopic setp2: [oracle@bd02 bin]$ ./kafka-console-consumer.sh --zookeeper 133.224.217.

i have charset question about kafka

2016-10-18 Thread /kun????????
i hava test my kafka programe using kafka-console-producer.sh and kafka-console-consumer.sh.

Consumer group indefinitely loops in rebalance problem

2019-02-28 Thread he kun
Hi, I’m using Kafka kafka_2.11-1.0.0 and the java client version is 0.10.1.0. The topic has 9 partitions and there are 2 processes each has 5 consumer threads consuming this topic. The consumer group indefinitely rebalances after the 2 processes started. This is the consumer config info

OutOfMemoryError when restart my Kafka Streams appplication

2019-04-15 Thread Kun Song
Hi community, I have encountered a Kafka Streams problem recently, and I have post it on stackoverflow[1], could anyone help me with this? Thanks you in advance :) [1] https://stackoverflow.com/questions/55690662/outofmemoryerror-when-restart-my-kafka-streams-appplication

Re: Can not compile kafka

2019-11-24 Thread Kun Song
There's a PR[1] which will enable gradle 6.0.1 to work with Kafka, hope it will be merged soon. 1. https://github.com/apache/kafka/pull/7677 On Thu, Nov 14, 2019 at 7:14 PM Miguel Silvestre wrote: > Hi, > > Thank you! That worked. I used gradle 5.6.4 and it worked, just out of the > box. > Let