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

2022-11-23 Thread John Roesler
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

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

2022-11-22 Thread Alexander Kau
My team is building a set of services that use Kafka Connect and Debezium to forward data changes from our Postgres database to Kafka, and then use Kafka Streams (via Spring Cloud Stream) to process this data and output an aggregate of the source data. We have been trying to track down an issue