Re: Kafka Stream custom join using state store

Hi, * "... the KTable update won't be trigger on the join on the Transformer." You are right, KStream-KTable join don't get trigger on KTable update https://docs.confluent.io/platform/current/streams/developer-guide/dsl-api.html#kstream-ktable-join Only input records for the left side (stream) tri

LeftJoin after Map operation

Hi List, There is a Join operation between a stream that is marked for repartition and a KTable that I can't make it work. The same left join works fine when I don't apply the Map operator (for changing key) so I must be doing something wrong with Serdes. The topology is: 1) Loading a KTable from

Docker-compose ssl_sasl example

Hello, I would like to configure my docker-compose setup to use kafka with SSL_SASL. To keep it simple I would like to use unencrypted communication between kafka and zookeeper. I'm still getting some errors in my current configuration. I've created simplified branch with kafka and zookeeper conta

Re: Please add user heyingquan to the list of contributors

Hi, I added you to the list of contributors in the Apache Kafka JIRA project. You can now assign tickets to yourself. Welcome to Apache Kafka! Best, Bruno On 05.06.21 15:44, 和映泉 wrote: Please add user heyingquan to the list of contributors.