We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
1.create tieredTopic bin/kafka-producer-perf-test.sh --topic tieredTopic0105 --num-records=100000000 --throughput 100000 --record-size 1000 --producer-props acks=1 batch.size=16384 bootstrap.servers=localhost:9092
bin/kafka-producer-perf-test.sh --topic tieredTopic0105 --num-records=100000000 --throughput 100000 --record-size 1000 --producer-props acks=1 batch.size=16384 bootstrap.servers=localhost:9092
2.produce messages with kafka-producer-perf-test bin/kafka-producer-perf-test.sh --topic test --num-records=100000000 --throughput 100000 --record-size 1000 --producer-props acks=1 batch.size=16384 bootstrap.servers=localhost:9092
bin/kafka-producer-perf-test.sh --topic test --num-records=100000000 --throughput 100000 --record-size 1000 --producer-props acks=1 batch.size=16384 bootstrap.servers=localhost:9092
3.consume with kafka-consumer-perf-test.sh bin/kafka-consumer-perf-test.sh --topic tieredTopic0105 --bootstrap-server localhost:9092 --messages 100000 --group test
bin/kafka-consumer-perf-test.sh --topic tieredTopic0105 --bootstrap-server localhost:9092 --messages 100000 --group test
broker uses aliyun oss as s3
The text was updated successfully, but these errors were encountered:
@freshtang just as reference, this is caused because of how timeouts are handled on the broker side, see #483 for future resolution.
As a workaround, consumers can increase their fetch.max.wait.ms to e.g. 2sec
fetch.max.wait.ms
Sorry, something went wrong.
No branches or pull requests
What happened?
1.create tieredTopic
bin/kafka-producer-perf-test.sh --topic tieredTopic0105 --num-records=100000000 --throughput 100000 --record-size 1000 --producer-props acks=1 batch.size=16384 bootstrap.servers=localhost:9092
2.produce messages with kafka-producer-perf-test
bin/kafka-producer-perf-test.sh --topic test --num-records=100000000 --throughput 100000 --record-size 1000 --producer-props acks=1 batch.size=16384 bootstrap.servers=localhost:9092
3.consume with kafka-consumer-perf-test.sh
bin/kafka-consumer-perf-test.sh --topic tieredTopic0105 --bootstrap-server localhost:9092 --messages 100000 --group test
What else do we need to know?
broker uses aliyun oss as s3
The text was updated successfully, but these errors were encountered: