;, "
> [email protected]<mailto:[email protected]>" <mailto:[email protected]>>
> Subject: Re: kafka producer-perf-test.sh compression-codec not working
>
> Hi Erik,
>
> Thanks for your inputs.
>
> How can we measure round trip latenc
[email protected]>"
mailto:[email protected]>>,
"[email protected]<mailto:[email protected]>"
mailto:[email protected]>>
Subject: Re: kafka producer-perf-test.sh compression-codec not working
Hi Erik,
Thanks for your inputs.
How can we measure ro
lto:[email protected]>>, "
> [email protected]<mailto:[email protected]>" <mailto:[email protected]>>
> Subject: Re: kafka producer-perf-test.sh compression-codec not working
>
> Hi Erik,
>
> I have put my efforts on the produce side till now, Tha
"[email protected]<mailto:[email protected]>"
mailto:[email protected]>>
Subject: Re: kafka producer-perf-test.sh compression-codec not working
Hi Erik,
I have put my efforts on the produce side till now, Thanks for making me aware
that consumer will decompress automa
Hi Prabhjot,
There are two important things to know about kafka compression: First
uncompression happens automatically in the consumer
(https://cwiki.apache.org/confluence/display/KAFKA/Compression) so you
should see ascii returned on the consumer side. The best way to see if
compression has happe
Hi Erik,
I have put my efforts on the produce side till now, Thanks for making me
aware that consumer will decompress automatically.
I'll also consider your point on creating real-life messages
But, I have still have one confusion -
Why would the current ProducerPerformance.scala compress an Ar
Hi,
I have bene trying to use kafka-producer-perf-test.sh to arrive at certain
benchmarks.
When I try to run it with --compression-codec values of 1, 2 and 3, I
notice increased throughput compared to NoCompressionCodec
But, When I checked the Producerperformance.scala, I saw that the the
`produc