回复: 你好,我发现了你们kafka-API文档的文本错误问题.

谢谢指正。已经提交了一个jira ticket [KAFKA-10222]准备修复了：） 发件人: Koray 发送时间: 2020年6月30日 23:06 收件人: users-subscribe ; users ; dev-subscribe ; dev ; dev ; dev-subscribe ; apache 主题: 你好,我发现了你们kafka-API文档的文本错误问题.

回复: Re:Re: [ANNOUNCE] New committer: Xi Hu

Thank you, everyone. It is my great honor to be a part of the community. Will make a greater contribution in the coming days. 发件人: Roc Marshal 发送时间: 2020年6月25日 10:20 收件人: users@kafka.apache.org 主题: Re:Re: [ANNOUNCE] New committer: Xi Hu Congratulations ! Xi

答复: [ANNOUNCE] New Committer: Dong Lin

Congrats, Dong Lin! 发件人: Matthias J. Sax 发送时间: 2018年3月29日 6:37 收件人: users@kafka.apache.org; d...@kafka.apache.org 主题: Re: [ANNOUNCE] New Committer: Dong Lin Congrats! On 3/28/18 1:16 PM, James Cheng wrote: > Congrats, Dong! > > -James >

答复: [ANNOUNCE] New Kafka PMC Member: Rajini Sivaram

Congratulations, Rajini Sivaram. Very well deserved! 发件人: Konstantine Karantasis 发送时间: 2018年1月18日 6:23 收件人: d...@kafka.apache.org 抄送: users@kafka.apache.org 主题: Re: [ANNOUNCE] New Kafka PMC Member: Rajini Sivaram Congrats Rajini!

答复: kafka.admin.TopicCommand Failing

Increasing `zookeeper.connection.timeout.ms` to a relatively larger value might be a help. Besides, you could check GC log to see if the STW pauses expired the Zk sessions. 发件人: Abhimanyu Nagrath 发送时间: 2017年11月17日 13:51 收件人:

答复: Kafka 0.9.0.1 partitions shrink and expand frequently after restart the broker

Seems broker `4759750` was always removed for partition [Yelp, 5] every round of ISR shrinking. Did you check if everything works alright for this broker? 发件人: Json Tu 发送时间: 2017年11月10日 11:08 收件人: users@kafka.apache.org 抄送:

答复: console consumer doesn't recognise localhost:2181 but only 127.0.0.1:2181

“Caused by: java.net.UnknownHostException: localhsot" - localhsot? A typo? 发件人: M. Manna 发送时间: 2017年7月7日 16:59 收件人: users@kafka.apache.org 主题: console consumer doesn't recognise localhost:2181 but only 127.0.0.1:2181 Hello, As part of

答复: 0.10.1.0 version kafka replica syn slow

If you confirm it's the reason, then try to increase `num.replica.fetchers` to speed up the replication. 发件人: 蔡高年 <838199...@qq.com> 发送时间: 2017年5月11日 11:45 收件人: users 主题: 0.10.1.0 version kafka replica syn slow hello recently ,our prod environment have a

答复: Trouble fetching messages with error "Skipping fetch for partition"

This is a trace-level log which means that consumer already creates a fetch request to the given node from which you are reading data so no more requests cannot be created. Did you get any other warn-level or error-level logs when failing to fetching message?

答复: Resetting offsets

Seems there is no command line out of box, but if you could write a simple Java client application that firstly calls 'seek' or 'seekToBeginning' to reset offsets to what you expect and then invoke commitSync to commit the offsets. 发件人: Paul van der Linden

答复: About "org.apache.kafka.common.protocol.types.SchemaException" Problem

Seems it's similar to https://issues.apache.org/jira/browse/KAFKA-4599? 发件人: Yang Cui 发送时间: 2017年4月27日 11:55 收件人: users@kafka.apache.org 主题: Re: About "org.apache.kafka.common.protocol.types.SchemaException" Problem Hi All, Have anyone can

答复: Re: How to choose one broker as Group Coordinator

Correct me if I am wrong. Firstly, determine the target partition of __consumer_offsets where the offset will be stored by calculating: Math.abs(groupID.hashCode() % 50) Secondly, find out the leader broker for that partition, and make that broker as the coordinator.

答复: Failing to get Topic Configuration

Seems you have to add some topic-level configs before seeing them. Run command below for an example: > bin/kafka-configs.sh --zookeeper localhost:2181 --entity-type topics > --entity-name my-topic --alter --add-config max.message.bytes=128000 发件人: Barot,