Re: Kafka SSL

2021-04-30 Thread Ran Lupovich
https://docs.confluent.io/platform/current/kafka/authentication_ssl.html Check this out בתאריך יום ו׳, 30 באפר׳ 2021, 20:06, מאת Ran Lupovich ‏< ranlupov...@gmail.com>: > Hi seems you setup in port 9093 only ssl as a method of authentication and > method of transfer encryption, so it means in

Re: Kafka SSL

2021-04-30 Thread Ran Lupovich
Hi seems you setup in port 9093 only ssl as a method of authentication and method of transfer encryption, so it means in the client configuration you would need the keystore configured as well, you could choose other mean of authentication such as PLAIN_SSL or so own, hope thats helps, keep us

Kafka SSL

2021-04-30 Thread Calvin Chen
Hi all I'm working on Kafka(kafka_2.13-2.7.0)cluster with SSL enabled, and I need help on Kafka broker config(I got error of connection failed) and client SSL config(I got error of SSL handshake failed). I setup Kafka and client SSL config by taking reference of Apache

Windowing and Aggregation across windows

2021-04-30 Thread saket kothari
Does aggregation happen per window..what if I want to use the agg result of a prev window on the next window?Is it possible? I have a one second window with grace period 5 mins.. When my first window expires , it will have some aggregate value and store it to another topic. Now, when my second

Identify clients that leak fetch sessions in a Kafka cluster

2021-04-30 Thread Martin Schneppenheim
In one of our Kafka clusters we noticed that fetch sessions are being evicted and lots of clients print `FETCH_SESSION_ID_NOT_FOUND` log messages. We tried to increase max.incremental.fetch.session.cache.slots from 1k to 10k in the brokers but the slots were immediately used up again and slots

Identify clients that leak fetch sessions in a Kafka cluster

2021-04-30 Thread Martin Schneppenheim
In one of our Kafka clusters we noticed that fetch sessions are being evicted and lots of clients print `FETCH_SESSION_ID_NOT_FOUND` log messages. We tried to increase max.incremental.fetch.session.cache.slots from 1k to 10k in the brokers but the slots were immediately used up again and slots