Kafka Stream: Cannot invoke "org.apache.kafka.streams.processor.internals.SourceNode.getTimestampExtractor()" because "source" is null

Hi: Every time, I restart my kafka stream app, it failed, and I have to reset the app, the error is: org.apache.kafka.streams.errors.StreamsException: stream-thread [microapi-unified-profile-data-sync.dit-1067669c-2364-440d-a1c3-69ad45cc301d-StreamThread-4] Failed to rebalance.

Re: [VOTE] 3.5.0 RC1

Hi Mickael, I ran the following validation steps: - Built from source with Java 11 and Scala 2.13 - Signatures and hashes of the artifacts generated - Navigated through Javadoc including links to JDK classes - Run the unit tests - Run integration tests - Run the quickstart in KRaft and Zookeeper m

[VOTE] 3.5.0 RC1

Hello Kafka users, developers and client-developers, This is the second candidate for release of Apache Kafka 3.5.0. Some of the major features include: - KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters - KIP-881: Rack-aware Partition Assignment for Kafka Consumers

Re: [VOTE] 3.4.1 RC3

Hi Prem, You need to remove yourself from the mailing list. Please find the details to do so here: https://kafka.apache.org/contact The interesting part for you is this: "To unsubscribe, send an email to users-unsubscr...@kafka.apache.org" Maybe you should also check if you are subscribed to t

Re: [VOTE] 3.4.1 RC3

Please remove my mail ID from the database. Warm Regards K Prem Sagar Sr.Manager - Procurements M: + 91 - 9100939886 p...@pidatacenters.com Amaravati | Bengaluru | Chennai | Delhi | Hyderabad | Kochi | Mumbai

Re: Warning logs: Mixing offset types

Hi, thanks for the reply! See comments below - On Mon, Jun 5, 2023 at 9:59 AM Richard Bosch wrote: > This message indicates that the transactional producer uses the send > offsets to transactions option. > We use, by default, transactional producers (setting a transaction.id). And most services

Re: [VOTE] 3.4.1 RC3

Hi Luke, Thanks a lot for the patience you had for this release! @Prem you are probably subscribed to either the user or dev mailing list for Apache Kafka, this is why you are receiving these emails. Best, On Mon, Jun 5, 2023 at 10:32 AM Prem Sagar wrote: > Why this mail is marked to me ?

Re: [VOTE] 3.4.1 RC3

Why this mail is marked to me ? Warm Regards K Prem Sagar Sr.Manager - Procurements M: + 91 - 9100939886 p...@pidatacenters.com Amaravati | Bengaluru | Chennai | Delhi | Hyderabad | Kochi | Mumbai

Re: [VOTE] 3.4.1 RC3

Hi Tom, Thanks for the vote. I've re-run the 3.4 jenkins build, and the `DynamicBrokerReconfigurationTest.testAdvertisedListenerUpdate` test still pass. https://ci-builds.apache.org/job/Kafka/job/kafka/job/3.4/142/ And now, I've got: Binding +1 PMC votes: * Chris Egerton * Mickael Maison * Tom Be

Re: Warning logs: Mixing offset types

Hi Anders, This message indicates that the transactional producer uses the send offsets to transactions option. It means that either another producer application is writing offsets for the consumer group as well or that you might be having a consumer and producer that adds offset to the transactio