回复: [ANNOUNCE] New committer: David Jacot

2020-10-18 Thread Hu Xi 
Congrats, David! Well deserved!



发件人: Vahid Hashemian 
发送时间: 2020年10月19日 11:17
收件人: dev 
主题: Re: [ANNOUNCE] New committer: David Jacot

Congrats David!

--Vahid

On Sun, Oct 18, 2020 at 4:23 PM Satish Duggana 
wrote:

> Congratulations David!
>
> On Sat, Oct 17, 2020 at 10:46 AM Boyang Chen 
> wrote:
> >
> > Congrats David, well deserved!
> >
> > On Fri, Oct 16, 2020 at 6:45 PM John Roesler 
> wrote:
> >
> > > Congratulations, David!
> > > -John
> > >
> > > On Fri, Oct 16, 2020, at 20:15, Konstantine Karantasis wrote:
> > > > Congrats, David!
> > > >
> > > > Konstantine
> > > >
> > > >
> > > > On Fri, Oct 16, 2020 at 3:36 PM Ismael Juma 
> wrote:
> > > >
> > > > > Congratulations David!
> > > > >
> > > > > Ismael
> > > > >
> > > > > On Fri, Oct 16, 2020 at 9:01 AM Gwen Shapira 
> > > wrote:
> > > > >
> > > > > > The PMC for Apache Kafka has invited David Jacot as a committer,
> and
> > > > > > we are excited to say that he accepted!
> > > > > >
> > > > > > David Jacot has been contributing to Apache Kafka since July
> 2015 (!)
> > > > > > and has been very active since August 2019. He contributed
> several
> > > > > > notable KIPs:
> > > > > >
> > > > > > KIP-511: Collect and Expose Client Name and Version in Brokers
> > > > > > KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies:
> > > > > > KIP-570: Add leader epoch in StopReplicaReques
> > > > > > KIP-599: Throttle Create Topic, Create Partition and Delete Topic
> > > > > > Operations
> > > > > > KIP-496 Added an API for the deletion of consumer offsets
> > > > > >
> > > > > > In addition, David Jacot reviewed many community contributions
> and
> > > > > > showed great technical and architectural taste. Great reviews are
> > > hard
> > > > > > and often thankless work - but this is what makes Kafka a great
> > > > > > product and helps us grow our community.
> > > > > >
> > > > > > Thanks for all the contributions, David! Looking forward to more
> > > > > > collaboration in the Apache Kafka community.
> > > > > >
> > > > > > --
> > > > > > Gwen Shapira
> > > > > >
> > > > >
> > > >
> > >
>


--

Thanks!
--Vahid

Re: [ANNOUNCE] New committer: David Jacot

2020-10-18 Thread Vahid Hashemian 
Congrats David!

--Vahid

On Sun, Oct 18, 2020 at 4:23 PM Satish Duggana 
wrote:

> Congratulations David!
>
> On Sat, Oct 17, 2020 at 10:46 AM Boyang Chen 
> wrote:
> >
> > Congrats David, well deserved!
> >
> > On Fri, Oct 16, 2020 at 6:45 PM John Roesler 
> wrote:
> >
> > > Congratulations, David!
> > > -John
> > >
> > > On Fri, Oct 16, 2020, at 20:15, Konstantine Karantasis wrote:
> > > > Congrats, David!
> > > >
> > > > Konstantine
> > > >
> > > >
> > > > On Fri, Oct 16, 2020 at 3:36 PM Ismael Juma 
> wrote:
> > > >
> > > > > Congratulations David!
> > > > >
> > > > > Ismael
> > > > >
> > > > > On Fri, Oct 16, 2020 at 9:01 AM Gwen Shapira 
> > > wrote:
> > > > >
> > > > > > The PMC for Apache Kafka has invited David Jacot as a committer,
> and
> > > > > > we are excited to say that he accepted!
> > > > > >
> > > > > > David Jacot has been contributing to Apache Kafka since July
> 2015 (!)
> > > > > > and has been very active since August 2019. He contributed
> several
> > > > > > notable KIPs:
> > > > > >
> > > > > > KIP-511: Collect and Expose Client Name and Version in Brokers
> > > > > > KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies:
> > > > > > KIP-570: Add leader epoch in StopReplicaReques
> > > > > > KIP-599: Throttle Create Topic, Create Partition and Delete Topic
> > > > > > Operations
> > > > > > KIP-496 Added an API for the deletion of consumer offsets
> > > > > >
> > > > > > In addition, David Jacot reviewed many community contributions
> and
> > > > > > showed great technical and architectural taste. Great reviews are
> > > hard
> > > > > > and often thankless work - but this is what makes Kafka a great
> > > > > > product and helps us grow our community.
> > > > > >
> > > > > > Thanks for all the contributions, David! Looking forward to more
> > > > > > collaboration in the Apache Kafka community.
> > > > > >
> > > > > > --
> > > > > > Gwen Shapira
> > > > > >
> > > > >
> > > >
> > >
>


-- 

Thanks!
--Vahid

Re: [ANNOUNCE] New committer: David Jacot

2020-10-18 Thread Satish Duggana 
Congratulations David!

On Sat, Oct 17, 2020 at 10:46 AM Boyang Chen  wrote:
>
> Congrats David, well deserved!
>
> On Fri, Oct 16, 2020 at 6:45 PM John Roesler  wrote:
>
> > Congratulations, David!
> > -John
> >
> > On Fri, Oct 16, 2020, at 20:15, Konstantine Karantasis wrote:
> > > Congrats, David!
> > >
> > > Konstantine
> > >
> > >
> > > On Fri, Oct 16, 2020 at 3:36 PM Ismael Juma  wrote:
> > >
> > > > Congratulations David!
> > > >
> > > > Ismael
> > > >
> > > > On Fri, Oct 16, 2020 at 9:01 AM Gwen Shapira 
> > wrote:
> > > >
> > > > > The PMC for Apache Kafka has invited David Jacot as a committer, and
> > > > > we are excited to say that he accepted!
> > > > >
> > > > > David Jacot has been contributing to Apache Kafka since July 2015 (!)
> > > > > and has been very active since August 2019. He contributed several
> > > > > notable KIPs:
> > > > >
> > > > > KIP-511: Collect and Expose Client Name and Version in Brokers
> > > > > KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies:
> > > > > KIP-570: Add leader epoch in StopReplicaReques
> > > > > KIP-599: Throttle Create Topic, Create Partition and Delete Topic
> > > > > Operations
> > > > > KIP-496 Added an API for the deletion of consumer offsets
> > > > >
> > > > > In addition, David Jacot reviewed many community contributions and
> > > > > showed great technical and architectural taste. Great reviews are
> > hard
> > > > > and often thankless work - but this is what makes Kafka a great
> > > > > product and helps us grow our community.
> > > > >
> > > > > Thanks for all the contributions, David! Looking forward to more
> > > > > collaboration in the Apache Kafka community.
> > > > >
> > > > > --
> > > > > Gwen Shapira
> > > > >
> > > >
> > >
> >

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #148

2020-10-18 Thread Apache Jenkins Server 
See

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #153

2020-10-18 Thread Apache Jenkins Server 
See

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #147

2020-10-18 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: fix potential NPE in PartitionData.equals (#9391)

[github] MINOR: Fix comment about 
AbstractFetcherThread.handlePartitionsWithError (#7205)


--
[...truncated 6.81 MB...]
org.apache.kafka.streams.TopologyTestDriverTest > 
shouldUseSourceSpecificDeserializersDeprecated[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldUseSourceSpecificDeserializersDeprecated[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldPunctuateIfEvenTimeAdvances[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldPunctuateIfEvenTimeAdvances[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowNoSuchElementExceptionForUnusedOutputTopicWithDynamicRouting[Eos 
enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowNoSuchElementExceptionForUnusedOutputTopicWithDynamicRouting[Eos 
enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > shouldInitProcessor[Eos 
enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > shouldInitProcessor[Eos 
enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowForUnknownTopic[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowForUnknownTopic[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldPunctuateOnStreamsTime[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldPunctuateOnStreamsTime[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldCaptureGlobalTopicNameIfWrittenInto[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldCaptureGlobalTopicNameIfWrittenInto[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = 
false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowIfInMemoryBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = 
false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldProcessFromSourcesThatMatchMultiplePattern[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldProcessFromSourcesThatMatchMultiplePattern[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > shouldPopulateGlobalStore[Eos 
enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > shouldPopulateGlobalStore[Eos 
enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = 
false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldThrowIfPersistentBuiltInStoreIsAccessedWithUntypedMethod[Eos enabled = 
false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled[Eos enabled = false] 
STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldAllowPrePopulatingStatesStoresWithCachingEnabled[Eos enabled = false] 
PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldReturnCorrectPersistentStoreTypeOnly[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldReturnCorrectPersistentStoreTypeOnly[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > shouldRespectTaskIdling[Eos 
enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > shouldRespectTaskIdling[Eos 
enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldUseSourceSpecificDeserializers[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldUseSourceSpecificDeserializers[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnAllStores[Eos 
enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > shouldReturnAllStores[Eos 
enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldNotCreateStateDirectoryForStatelessTopology[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldNotCreateStateDirectoryForStatelessTopology[Eos enabled = false] PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies[Eos enabled = false] 
STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldApplyGlobalUpdatesCorrectlyInRecursiveTopologies[Eos enabled = false] 
PASSED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldReturnAllStoresNames[Eos enabled = false] STARTED

org.apache.kafka.streams.TopologyTestDriverTest > 
shouldReturnAllStoresNames[Eos enabled = false] PASSED

[jira] [Created] (KAFKA-10617) Cached zkVersion 102 not equal to that in zookeeper, skip updating ISR (kafka.cluster.Partition)

2020-10-18 Thread Daniel (Jira) 
Daniel created KAFKA-10617:
--

 Summary: Cached zkVersion 102 not equal to that in zookeeper, skip 
updating ISR (kafka.cluster.Partition)
 Key: KAFKA-10617
 URL: https://issues.apache.org/jira/browse/KAFKA-10617
 Project: Kafka
  Issue Type: Bug
  Components: controller
Affects Versions: 2.4.1
Reporter: Daniel


This may be related to:

https://issues.apache.org/jira/browse/KAFKA-2729

however all evidence on that, indicates this was fixed ~2.2.0, ad we are seeing 
this in 2.4.1

 

This hit us in middle of night, are tps moving into the incident was very 
low..~15tps, after the incident due to offset going back in time r tps shotup 
to 40k for the next 2 hours, prior to us shutting down the cluster, resetting 
offset position.

This bug led to our offsets going back in time, causing us to re-process 
messages from 'days' ago.

 

 

 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #152

2020-10-18 Thread Apache Jenkins Server 
See 


Changes:

[github] MINOR: fix potential NPE in PartitionData.equals (#9391)


--
[...truncated 3.43 MB...]
org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@897d264, 
timestamped = false, caching = false, logging = true] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@58681e0e, 
timestamped = false, caching = false, logging = true] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@58681e0e, 
timestamped = false, caching = false, logging = true] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@9307a95, 
timestamped = false, caching = false, logging = true] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@9307a95, 
timestamped = false, caching = false, logging = true] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@5592758f, 
timestamped = false, caching = false, logging = false] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@5592758f, 
timestamped = false, caching = false, logging = false] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@63a089ab, 
timestamped = false, caching = false, logging = false] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@63a089ab, 
timestamped = false, caching = false, logging = false] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@7ba073bf, 
timestamped = false, caching = false, logging = false] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.WindowStoreBuilder@7ba073bf, 
timestamped = false, caching = false, logging = false] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@71ce5a8c, 
timestamped = false, caching = true, logging = true] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@71ce5a8c, 
timestamped = false, caching = true, logging = true] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@37366737, 
timestamped = false, caching = true, logging = true] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@37366737, 
timestamped = false, caching = true, logging = true] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@50bc4dab, 
timestamped = false, caching = true, logging = false] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@50bc4dab, 
timestamped = false, caching = true, logging = false] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@2879e188, 
timestamped = false, caching = true, logging = false] STARTED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@2879e188, 
timestamped = false, caching = true, logging = false] PASSED

org.apache.kafka.streams.test.MockProcessorContextStateStoreTest > 
shouldEitherInitOrThrow[builder = 
org.apache.kafka.streams.state.internals.SessionStoreBuilder@2b60c431, 
timestamped = false, caching = false, logging = true] STARTED

[GitHub] [kafka-site] chia7712 merged pull request #304: Add chia7712 to committers

2020-10-18 Thread GitBox 


chia7712 merged pull request #304:
URL: https://github.com/apache/kafka-site/pull/304


   



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

[GitHub] [kafka-site] chia7712 commented on pull request #304: Add chia7712 to committers

2020-10-18 Thread GitBox 


chia7712 commented on pull request #304:
URL: https://github.com/apache/kafka-site/pull/304#issuecomment-711161869


   @guozhangwang Thanks for confirming. Merge it to trunk :)



This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org