Build failed in Jenkins: kafka-2.2-jdk8 #89

See Changes: [bbejeck] KAFKA-7895: fix Suppress changelog restore (#6536) (#6615) -- [...truncated 2.70 MB...] kafka.controller.PartitionStateMachineTest >

Re: [VOTE] KIP-421: Automatically resolve external configurations.

Hi Dongjin, Thanks for checking out the KIP. Randall is a committer, actually. He was added two months ago. It looks like he isn't on the committers page yet, though. Randall, can you add your name to https://kafka.apache.org/committers.html to help prevent confusion in the future? best,

Re: [ANNOUNCE] New Kafka PMC member: Sriharsh Chintalapan

Congrats, Harsh! On Tue, Apr 23, 2019 at 5:41 AM Colin McCabe wrote: > Congratulations, Harsh! > > cheers, > Colin > > > On Thu, Apr 18, 2019, at 11:46, Jun Rao wrote: > > Hi, Everyone, > > > > Sriharsh Chintalapan has been active in the Kafka community since he > became > > a Kafka committer

Build failed in Jenkins: kafka-trunk-jdk11 #457

See Changes: [rhauch] KAFKA-8277: Fix NPEs in several methods of ConnectHeaders (#6550) [wangguoz] KAFKA-8204: fix Streams store flush order (#6555) [github] MINOR: Move log statement stating producer closed

Re: [ANNOUNCE] New Kafka PMC member: Matthias J. Sax

Congrats, Matthias! On Sat, Apr 20, 2019 at 10:28 AM Matthias J. Sax wrote: > Thank you all! > > -Matthias > > > On 4/19/19 3:58 PM, Lei Chen wrote: > > Congratulations Matthias! Well deserved! > > > > -Lei > > > > On Fri, Apr 19, 2019 at 2:55 PM James Cheng > >

Build failed in Jenkins: kafka-2.2-jdk8 #88

See Changes: [rhauch] KAFKA-8277: Fix NPEs in several methods of ConnectHeaders (#6550) [wangguoz] KAFKA-8204: fix Streams store flush order (#6555) -- [...truncated 2.70

Re: [VOTE] KIP-421: Automatically resolve external configurations.

Hi all, This KIP passes with three +1 (binding) - thanks Colin, Randall and Gwen! For those interested, feel free to check out and join the ongoing PR review here: https://github.com/apache/kafka/pull/6467 Thanks, Tejal On 2019/04/22 17:26:05, TEJAL ADSUL wrote: > Hi Folks, > > Just a

Build failed in Jenkins: kafka-1.1-jdk7 #261

See Changes: [rhauch] KAFKA-8277: Fix NPEs in several methods of ConnectHeaders (#6550) -- [...truncated 426.29 KB...] kafka.server.KafkaConfigTest >

Build failed in Jenkins: kafka-2.0-jdk8 #253

See Changes: [rhauch] KAFKA-8277: Fix NPEs in several methods of ConnectHeaders (#6550) -- [...truncated 440.23 KB...] kafka.log.LogCleanerManagerTest >

Build failed in Jenkins: kafka-trunk-jdk8 #3576

See Changes: [github] MINOR: Use https instead of http in links (#6477) [github] MINOR: log which signals are handled on startup (#6620) -- [...truncated 4.77 MB...]

Re: [VOTE] KIP-421: Automatically resolve external configurations.

I just read the KIP. +1. Currently: Binding: +2 (Colin, Gwen) Non-binding: +2 (Randall, Dongjin) Thanks, Dongjin On Mon, Apr 22, 2019 at 10:26 AM TEJAL ADSUL wrote: > Hi Folks, > > Just a reminder that I will be closing the vote for KIP-421 by today EOD, > please cast your votes by today. >

Re: [DISCUSS] KIP-458: Connector Client Config Override Policy

Hi Magesh, This is an exciting KIP! I have a few questions/comments but overall I like the direction it's headed in and hope to see it included in the Connect framework soon. 1. With the proposed "consumer.", "producer.", and "admin." prefixes, how will this interact with connectors such as the

[jira] [Resolved] (KAFKA-8204) Streams may flush state stores in the incorrect order

[ https://issues.apache.org/jira/browse/KAFKA-8204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8204. -- Resolution: Fixed Fix Version/s: (was: 2.1.2) (was: 2.0.2)

Re: [ANNOUNCE] New Kafka PMC member: Sriharsh Chintalapan

Congratulations, Harsh! cheers, Colin On Thu, Apr 18, 2019, at 11:46, Jun Rao wrote: > Hi, Everyone, > > Sriharsh Chintalapan has been active in the Kafka community since he became > a Kafka committer in 2015. I am glad to announce that Harsh is now a member > of Kafka PM > > Congratulations,

[jira] [Resolved] (KAFKA-8277) Fix NPE in ConnectHeaders

[ https://issues.apache.org/jira/browse/KAFKA-8277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8277. -- Resolution: Fixed > Fix NPE in ConnectHeaders > - > >

[jira] [Created] (KAFKA-8277) Fix NPE in ConnectHeaders

Randall Hauch created KAFKA-8277: Summary: Fix NPE in ConnectHeaders Key: KAFKA-8277 URL: https://issues.apache.org/jira/browse/KAFKA-8277 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-440: Extend Connect Converter to support headers

I think it would be helpful to clarify this in the KIP, just so that readers are aware that the headers will be the raw header bytes that are the same as what is in the Kafka record. The alternative I was referring to is exposing the Connect `Headers` interface, which is different. On Mon, Apr

Build failed in Jenkins: kafka-trunk-jdk8 #3575

See Changes: [github] MINOR: Add unit test for SerDe auto-configuration (#6610) -- [...truncated 2.38 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

Re: [DISCUSS] KIP-440: Extend Connect Converter to support headers

Hi Konstantine, Randall, As you can see in the updated Converter interface, it always operates on `org.apache.kafka.common.header.Headers`. WorkerSinkTask simply uses Kafka message headers and passes them to the `toConnectData` method. WorkerSourceTask leverages header converter to extract

Re: [DISCUSS] KIP-440: Extend Connect Converter to support headers

Konstantine raises a good point. Which `Headers` is being referenced in the API? The Connect `org.apache.kafka.connect.header.Headers` would correspond to what was already deserialized by the `HeaderConverter` or what will yet be serialized by the `HeaderConverter`. Alternatively, the common `

Re: [VOTE] KIP-421: Automatically resolve external configurations.

Hi Folks, Just a reminder that I will be closing the vote for KIP-421 by today EOD, please cast your votes by today. Thanks Colin, Randall, Gwen for the votes. Thanks, Tejal On 2019/04/19 22:43:25, "Colin McCabe" wrote: > +1. Thanks, Tejal. > > best, > Colin > > On Thu, Apr 18, 2019,

Re: [DISCUSS] KIP-440: Extend Connect Converter to support headers

Thanks for the KIP Yaroslav! Apologies for the late comment. However, after reading the KIP it's still not very clear to me what happens to the existing HeaderConverter interface and what's the expectation for existing code implementing this interface out there. Looking at the PR I see that the

[jira] [Created] (KAFKA-8276) Schema Registry Security settings as Props

Karthik Murugesan created KAFKA-8276: Summary: Schema Registry Security settings as Props Key: KAFKA-8276 URL: https://issues.apache.org/jira/browse/KAFKA-8276 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-440: Extend Connect Converter to support headers

Thanks for updating the KIP. It looks good to me, and since there haven't been any other issue mentioned in this month-long thread, it's probably fine to start a vote. Best regards, Randall On Tue, Apr 2, 2019 at 3:12 PM Randall Hauch wrote: > Thanks for the submission, Yaroslav -- and for

[jira] [Created] (KAFKA-8275) NetworkClient leastLoadedNode selection should consider throttled nodes

Jason Gustafson created KAFKA-8275: -- Summary: NetworkClient leastLoadedNode selection should consider throttled nodes Key: KAFKA-8275 URL: https://issues.apache.org/jira/browse/KAFKA-8275 Project:

Re: [VOTE] KIP-446: Add changelog topic configuration to KTable suppress

Hi Maarten, Congratulations, your KIP has 3 binding votes, no vetoes, and has been open for over 72 hours, so you can close the vote and submit a PR for review! The way to close the vote is you just reply to this thread and tally up the votes, and say that the KIP vote has passed (see the other

[jira] [Created] (KAFKA-8274) Old Committed messages got replayed after Kafka cluster Restart

Hrishikesh tiwary created KAFKA-8274: Summary: Old Committed messages got replayed after Kafka cluster Restart Key: KAFKA-8274 URL: https://issues.apache.org/jira/browse/KAFKA-8274 Project: Kafka

[jira] [Created] (KAFKA-8273) Admin client doesn't reestablish connection on Broker restart

Christian Yotov created KAFKA-8273: -- Summary: Admin client doesn't reestablish connection on Broker restart Key: KAFKA-8273 URL: https://issues.apache.org/jira/browse/KAFKA-8273 Project: Kafka