回复: Unused options in ConsumerPerformance

Hi Ricardo, I was a little confused about the function of Jira tickets and mailing list. Thanks for your clarify. I have created one, https://issues.apache.org/jira/browse/KAFKA-10126 发件人: Ricardo Ferreira 发送时间: 2020年6月9日 19:58 收件人: users@kafka.apache.org; Jiamei Xie 主题: Re: Unused options

Unused options in ConsumerPerformance

/ConsumerPerformance.scala and found that numThreadsOpt and numFetchersOpt are not used. Best wishes Jiamei Xie IMPORTANT NOTICE: The contents of this email and any attachments are confidential and may also be privileged. If you are not the intended recipient, please notify the sender immediately

RE: Is that a bug?

To: users@kafka.apache.org Subject: Re: Is that a bug? Hey Xie, On Fri, 22 May 2020 at 08:31, Jiamei Xie wrote: > Hi > > Kill all zookeeper and kafka process. Clear zookeeper and kafka data dir. > Restart zookeeper and kafka. If there are any active client. Topic > used by clie

Is that a bug?

Hi Kill all zookeeper and kafka process. Clear zookeeper and kafka data dir. Restart zookeeper and kafka. If there are any active client. Topic used by client will be auto-created. How to reproduce? 1. Start zookeeper and kafka zookeeper and kafka config file. nohup

Request for adding into contributors list

Hi, Please add my JIRA ID into the contributors list of Apache Kafka. Here is my JIRA profile: Username: adally Full name: jiamei xie Best Wishes, Jiamei IMPORTANT NOTICE: The contents of this email and any attachments are confidential and may also be privileged. If you

How commits are tested for kafka? travis or jenkins?

Hi all, In .travis.yml , /bin/bash ./tests/docker/run_tests.sh is included in script, which will cost a lot time. And I noticed there is a file jenkins.sh. After commiting a patch, email from bui...@travis-ci.com is received. And I looked into errors , it seems

How is decompress called in DefaultRecordBatch#iterator

Hi all， There are huge latency gap between arm and x86 when running kafka-producer-perf-test.sh with compression set, especially when the codec is zstd. So I looked into the source code. It seems the response from broker server is too slow for arm. And the

Producer MESSAGE_TOO_LARGE warnning when compression is zstd

Hi, Issue: The MESSAGE_TOO_LARGE warning occurred when I run producer-perf-test.sh and the broker is arm server. Below it’s the command I used: bin/kafka-topics.sh --create --bootstrap-server arm-server:9092 --replication-factor 1 --partitions 6 --topic test bin/kafka-producer-perf-test.sh