Re: Beginner Issues connecting to kafka with SSL (using kafka connector)

2025-07-23 Thread Chris Egerton
Hi Domantas, For sink connectors, you'll need to add all SSL-related properties either to your Connect worker file prefixed with "consumer.", or to your individual connector files prefixed with "consumer.override.". If you're using the DLQ feature, you'll also need to do the same but with "admin.

Beginner Issues connecting to kafka with SSL (using kafka connector)

2025-07-23 Thread Domantas Spečiūnas
HI, I have issue connecting to to kafka with SSL, tried a lot of options and stuck, maybe someone can suggest what is wrong here, on clickhouse side everything is fine: [root@server.tld01 config]# cat connect-distributed.properties | grep -v ^# | grep -v '^$' group.id=connect-cluster key.convert

About regression introduced in KIP-962 fixed in KAFKA-19208

2025-07-23 Thread Sébastien
Hi everyone, I'm upgrading my old Kafka Stream application currently in 2.6. to 3.8.1 version. But I'm facing a bug where some KStream-GlobalKTable left join doesn't work anymore and instead Drop records, and that's a regression from my 2.6.1 version. What I have is a Kstream With K1,V1 Avro rec

Re: About regression introduced in KIP-962 fixed in KAFKA-19208

2025-07-23 Thread Matthias J. Sax
Hello Sébastien, thanks for reaching out. The fix was not back ported to 3.x branches, because it is very unlikely that there will be another 3.x bug fix release. Kafka community usually only does bug-fix releases for the last minor release, and there was already 3.9.1. With 4.1.0 being in th

Kafka Queues (KIP-932) and Kafka Connect?

2025-07-23 Thread Brebner, Paul
Hi, Curious if anyone has thought about using Kafka Queues (KIP-932) with Kafka Connect in the future? I.e. autoscaling connect tasks? There could be some Connect use cases where order isn’t as important as keeping up with load spikes, maybe. Regards, Paul Brebner NetApp Instaclustr Technology