Re: [ANNOUNCE] New Committer: Randall Hauch

Congrats! > On Feb 15, 2019, at 10:16, Guozhang Wang wrote: > > Hello all, > > The PMC of Apache Kafka is happy to announce another new committer joining > the project today: we have invited Randall Hauch as a project committer and > he has accepted. > > Randall has been participating in the

Re: [ANNOUNCE] New Committer: Vahid Hashemian

Congrats! > On Jan 16, 2019, at 10:08, Srinivas Reddy wrote: > > Congratulation Vahid!!! > > >> On 16 Jan 2019, at 9:58 AM, Manikumar wrote: >> >> Congrats, Vahid! >> >> On Wed 16 Jan, 2019, 6:53 AM Ismael Juma > >>> Congratulations Vahid! >>> >>> On Tue, Jan 15, 2019, 2:45 PM Jason

How to find client.id according to connection id

Hi, I have a connection id from broker in this format $localHost:$localPort-$remoteHost:$remotePort , how can I find the related client.id ?

Marking the coordinator dead and stopped commit offsets

Hi, In kafka 0.10, if kafka consumer log “Marking the coordinator dead ..” “auto commit offset failed ..” then the consumer will not commit the offset any more. is there any issues about this, more details in this:

Re: consumer fetch multiple topic partitions committed offset

committed()` multiple times. > > -Matthias > > On 11/1/18 12:28 AM, hacker win7 wrote: >> Hi, >> >> After reviewing the KafkaConsumer source about API of *committed():* >> I found that old consumer support committed(mutipleTopicPartitions) to >> retu

consumer fetch multiple topic partitions committed offset

Hi, After reviewing the KafkaConsumer source about API of *committed():* I found that old consumer support committed(mutipleTopicPartitions) to return multiple committed offset, while in new consumer, there is only committed(singleTopicPartition) and return only one committed offset. It is a

Re: New increased partitions could not be rebalance, until stop all consumers and start them

You can add the config *props.put("metadata.max.age.ms ", 5000);* to your cases, and re-test it. 飞翔的加菲猫 <526564...@qq.com> 于2018年10月18日周四 上午10:47写道： > Sorry for bothering. I don't know whether it is a bug. Maybe something > wrong in my test or there is explanation for

Re: Kafka_2.12-1.1.0 config

bin/kafka-console-producer.sh add --producer.config your_producer.properties file. you don't add --producer.config , you still use the default value of max.request.size. sarath reddy 于2018年9月21日周五 上午12:27写道： > ++pushkar > > On Thu 20 Sep, 2018, 16:20 sarath reddy, wrote: > > > Hi Team, > > > >