Re: Punctuate NPE

Hi Navneeth, I'm sorry for the trouble. Which version of Streams are you using? Also, this doesn't look like the full stacktrace, since we can't see the NPE itself. Can you share the whole thing? Thanks, -John On Tue, 2020-12-15 at 00:30 -0800, Navneeth Krishnan wrote: > Hi All, > > I have a

Re: [VOTE] 2.7.0 RC5

All, I'm closing this vote in order to get this critical PR CVE-2020-25649: bumping jackson to patched version merged into 2.7. Once we merge the PR, I'll push out a new RC. Thanks to all who voted for this RC. Bill On Tue, Dec 15, 2020 at 1:16 PM

Re: ProducerFencedException

Can you verify that the used UUIDs are non-overlapping? Also, can you verify if the broker expires a TX? The logs should tell you. -Matthias On 12/14/20 9:09 PM, Indu V wrote: > Hi Team, > > I am facing an issue in a single Kafka environment trying to connect from > multiple application

Re: KIP to Gracefully handle timeout exception on kafka streams

Sounds like `default.api.timeout.ms`. -Matthias On 12/11/20 8:22 AM, Pushkar Deole wrote: > Matthias, > > By the way, one more of our service recently encountered this exception: > can you suggest if this can also be avoided by tuning any specific > configuration ? > >

Re: [VOTE] 2.7.0 RC5

Hi Bill, Just a heads up that KAFKA-9393 that was previously marked as fixed in 2.7.0 has now been changed to 2.8.0. The corresponding PR is not present in 2.7.0 commit history. Please could you regenerate the release notes to help pick up this change? Cheers, Kowshik On Tue, Dec 15, 2020 at

Re: Apache Kafka Powered By : Proposition La Redoute

Hi Antoine, Thanks for your message! I couldn't see the logo; I think the mailing list software doesn't transmit attachments. Perhaps you could just send a pull request to add La Redoute to https://github.com/apache/kafka-site/edit/asf-site/powered-by.html ? Feel free to reply here if you have

Re: [VOTE] 2.7.0 RC5

Thanks for voting John, I'm cc'ing the dev list as well. On Mon, Dec 14, 2020 at 8:35 PM John Roesler wrote: > Thanks for this release, Bill, > > I ran though the quickstart (just the zk, broker, and > console clients part), verified the signatures, and also > built and ran the tests. > > I'm

Re: [VOTE] 2.7.0 RC5

Thanks for voting Guozhang. Including the dev list as well. On Mon, Dec 14, 2020 at 5:59 PM Guozhang Wang wrote: > I checked the docs and ran unit tests, no red flags found. +1. > > On Fri, Dec 11, 2020 at 5:45 AM Bill Bejeck wrote: > > > Updated with link to successful Jenkins build. > > > >

Re: Announcing #TwelveDaysOfSMT

Hey Ryanne, Apologies; I thought as these Single Message Transforms are all part of Apache Kafka this would be ok, but I am happy to not post any more :) If anyone does want to see the others, they'll all be linked to and they're published from https://rmoff.net/categories/twelvedaysofsmt/

Re: [VOTE] 2.6.1 RC3

+1 (binding) Verified signatures, ran tests from source build (one flaky test failed but passed on rerun), ran Kafka quick start with the binary with both Scala 2.12 and Scala 2.13. Thanks for running the release, Mickael! Regards, Rajini On Fri, Dec 11, 2020 at 3:23 PM Mickael Maison wrote:

Punctuate NPE

Hi All, I have a scheduled function that runs every 10 seconds and in some cases I see this NPE. Not sure how to debug this issue. Any pointers would really help. Thanks context.schedule(this.scheduleInterval, PunctuationType.STREAM_TIME, this::flush); 2020-12-15 07:40:14.214

Re: Kafka Streams - Source Partition Assignment Issue

In addition to the assignment issue I see the state of the application changes every few minutes from Running to Rebalancing. Other than the default configs only the below two extra config parameters are set. Currently there are 10 instances and they are constantly rebalancing. fetch-max-wait: