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 hava test my kafka programe using kafka-console-producer.sh and
kafka-console-consumer.sh.
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
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
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