Re: Consume data-skewed partitions using Kafka-streams causes consumer load balancing issue.

2022-07-13 Thread Guozhang Wang
Hello Ankit, Kafka Streams's rebalance protocol is trying to balance workloads based on the num.partitions (more specifically, the num.tasks which is derived from the input partitions) but not on the num.messages or num.bytes, so they would not be able to handle data-skewness across partitions

Re: Inquiry about using SSL encryption and SASL authentication for Kafka without specifying IP address in SAN in the CA certificate

2022-07-13 Thread Richard Bosch
Hi Deepak, I'm not sure what you mean by IP in the CA certificate? The CA certificates are used to determine who signed a provided certificate and if it is valid. So when I connect to a broker using an IP address, then the server must provide a server certificate containing the IP as SAN to

DataMass Summit waiting for a speakers

2022-07-13 Thread Klaudia Wachnio
Dear Hadoop Community, CFP for DataMass GdaƄsk Summit has been extended! You can join the event and share your experience by submitting the presentation proposal till the 15th July 2022. What is the