Kafka Streams output topic configuration (specifically: Quarkus)

2024-02-14 Thread Karsten Stöckmann
Hi, is anyone here familiar with Quarkus Kafka Streams applications? If so - is there a way to control output topic configuration when streaming aggregate data into a sink like so: KTable aggregate = ...; aggregate.toStream().to("topic", ); -> Can I programmatically (or by application config) de

Re: Is it possible to include only the connector name in worker logs?

2024-02-14 Thread Greg Harris
Hey Yeikel, Thanks for your question! It appears that we only expose the already-concatenated data to the logs: https://github.com/apache/kafka/blob/e8c70fce26626ed2ab90f2728a45f6e55e907ec1/connect/runtime/src/main/java/org/apache/kafka/connect/util/LoggingContext.java#L186-L204 instead of letti

Re: [VOTE] 3.7.0 RC4

2024-02-14 Thread Paolo Patierno
+1 (non-binding). I used the staged binaries with Scala 2.13 and mostly focused on the ZooKeeper to KRaft migration with multiple tests. Everything works fine. Thanks Paolo On Mon, 12 Feb 2024, 22:06 Jakub Scholz, wrote: > +1 (non-binding). I used the staged binaries with Scala 2.13 and the sta