Hi Steven - what are pause times, gc and memory usage on Kafka brokers? When
pause times are high kafka broker disconnects from zk. goes out of cluster and
rejoins later makes shrink and expand on isr.
> On May 2, 2019, at 5:39 PM, Steven Taschuk
> wrote:
>
> Our kafka broker logs show
Hi Bruno,
thank you for your help, glad to hear that those are only bugs and not a
problem on my implementation,
I'm currently using confluent docker images, I've checked their master
branch which seems to use the SNAPSHOT version however those
images/packages aren't publicly available. Are there
If you can access the remote file via a mounted filesystem, you can specify
'/mountpoint/truststore.jks’ as the value for ssl.truststore.location. You
cannot use a url to specify a remote resource.
> On May 2, 2019, at 11:38 AM, anurag wrote:
>
> Hi All,
>
> Is it possible to set the value o
Hi,
I have a Kafka Streams application where I am joining a KStream that reads
from "topic1" with a GlobalKTable that reads from "topic2" and then with
another GlobalKTable that reads from "topic3". Here is the pseudo code -
> KStream topic1KStream =
> builder.stream(
>
Our kafka broker logs show episodes where several partitions have
"Shrinking ISR ..." messages followed, usually less than 2 seconds
later, by corresponding "Expanding ISR ..." messages that restore the
original set of brokers for all the partitions. Does anyone have any
suggestions on how to inve
Hi All,
Is it possible to set the value of ssl.truststore.location to a location on
remote host. Basically I have ssl certificates available on remote host and
i would like my docker kafka container to read and use certificates from
remote location. If this is possible can you please provide an ex
OK Senthil
Thanks for your support and cooperation
Sent from Outlook
OK Senthil
Thanks for your support and cooperation
Sent from Outlook
