Re: Stream sinks are not constructed when application starts up before Kafka broker

Hi Alexander, I’m sorry to hear that. It certainly sounds like a hard one to debug. To clarify, do you mean that when you observe this problem, the sink node is not in the topology at all, or that it is in the topology, but does not function properly? Also, are you using Spring to construct t

Kafka 4.x release date

Good morning, we are using for our product (Fare Collection System Ticketing) Apache Kafka software. https://www.scheidt-bachmann.de/en/fare-collection-systems/home One of task is update logging from version1 to version2. https://issues.apache.org/jira/browse/KAFKA-9366 Based on this link inf

Re: same keys appearing in state stores on different pods when using branches in kafka streams

Hi Pushkar, Thanks for the question. I think that what’s happening is that, even though both branches use the same grouping logic, Streams can’t detect that they are the same. It just sees two group-bys and therefore introduces two repartitions, with a separate downstream task for each. You mi

Active <> Active MirrorMaker2 setup via dedicated Kafka Connect cluster

Hi, I am trying to set up active <> active mm2 via Kafka connect distributed cluster. It seems not possible because of the limitations like *bootstrap.servers *property. And also as per this KIP https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0#KIP382:MirrorMaker2.0-Runn

same keys appearing in state stores on different pods when using branches in kafka streams

Hi All, I have a stream application that creates 2 branches. Each branch includes a state store where the status field of the kafka message determines the branch, and therefore the state store used: Status OPEN = State store name totals Status CLOSED = State store name records I’m seeing tha