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

See Changes: [jason] KAFKA-7763; Calls to commitTransaction and abortTransaction should not [bbejeck] MINOR: Missing punctuation marks in quickstart (#5755) -- [...trunca

Re: [VOTE] KIP-430 - Return Authorized Operations in Describe Responses

+1 On Thu, Feb 21, 2019 at 2:28 AM Rajini Sivaram wrote: > > I would like to start vote on KIP-430 to optionally obtain authorized > operations when describing resources: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-430+-+Return+Authorized+Operations+in+Describe+Responses > > Thank y

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

See Changes: [bbejeck] MINOR: Missing punctuation marks in quickstart (#5755) -- [...truncated 2.33 MB...] org.apache.kafka.streams.StreamsConfigTest > testGetRestoreCons

[jira] [Created] (KAFKA-7980) Flaky Test SocketServerTest#testConnectionRateLimit

Matthias J. Sax created KAFKA-7980: -- Summary: Flaky Test SocketServerTest#testConnectionRateLimit Key: KAFKA-7980 URL: https://issues.apache.org/jira/browse/KAFKA-7980 Project: Kafka Issue T

[jira] [Created] (KAFKA-7979) Flaky Test PartitionTest#testDelayedFetchAfterAppendRecords

Matthias J. Sax created KAFKA-7979: -- Summary: Flaky Test PartitionTest#testDelayedFetchAfterAppendRecords Key: KAFKA-7979 URL: https://issues.apache.org/jira/browse/KAFKA-7979 Project: Kafka

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

See Changes: [vahid.hashemian] Update kafka-run-class.bat (#6291) [github] MINOR: Subscribe/assign calls should be logged at info level (#6299) [github] MINOR: Handle Metadata v0 all topics requests during pars

[jira] [Created] (KAFKA-7978) Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups

Matthias J. Sax created KAFKA-7978: -- Summary: Flaky Test SaslSslAdminClientIntegrationTest#testConsumerGroups Key: KAFKA-7978 URL: https://issues.apache.org/jira/browse/KAFKA-7978 Project: Kafka

[jira] [Created] (KAFKA-7977) Flaky Test ReassignPartitionsClusterTest#shouldOnlyThrottleMovingReplicas

Matthias J. Sax created KAFKA-7977: -- Summary: Flaky Test ReassignPartitionsClusterTest#shouldOnlyThrottleMovingReplicas Key: KAFKA-7977 URL: https://issues.apache.org/jira/browse/KAFKA-7977 Project:

[jira] [Created] (KAFKA-7976) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

Matthias J. Sax created KAFKA-7976: -- Summary: Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable Key: KAFKA-7976 URL: https://issues.apache.org/jira/browse/KAFKA-7976 Project

Jenkins build is back to normal : kafka-trunk-jdk11 #306

See

[jira] [Created] (KAFKA-7975) Provide client API version to authorizer

Ying Zheng created KAFKA-7975: - Summary: Provide client API version to authorizer Key: KAFKA-7975 URL: https://issues.apache.org/jira/browse/KAFKA-7975 Project: Kafka Issue Type: Improvement

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

See Changes: [jason] MINOR: Subscribe/assign calls should be logged at info level (#6299) -- [...truncated 2.67 MB...] kafka.utils.SchedulerTest > testPeriodicTask PASSED ka

[jira] [Resolved] (KAFKA-5510) Streams should commit all offsets regularly

[ https://issues.apache.org/jira/browse/KAFKA-5510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5510. Resolution: Won't Do > Streams should commit all offsets regularly > --

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

See Changes: [vahid.hashemian] Update kafka-run-class.bat (#6291) [github] MINOR: Subscribe/assign calls should be logged at info level (#6299) [github] MINOR: Handle Metadata v0 all topics requests during pars

[jira] [Created] (KAFKA-7974) KafkaAdminClient loses worker thread/enters zombie state when initial DNS lookup fails

Nicholas Parker created KAFKA-7974: -- Summary: KafkaAdminClient loses worker thread/enters zombie state when initial DNS lookup fails Key: KAFKA-7974 URL: https://issues.apache.org/jira/browse/KAFKA-7974

Jenkins build is back to normal : kafka-2.1-jdk8 #134

See

Re: [DISCUSS] KIP-307: Allow to define custom processor names with KStreams DSL

Hi Florian, Overall the KIP LGTM. Once you've addressed the final comments from Matthias I think we can put this up for a vote. Thanks, Bill On Wed, Feb 20, 2019 at 9:42 PM Matthias J. Sax wrote: > Florian, > > thanks for updating the KIP (and no worries for late reply -- 2.2 > release kept u

[jira] [Resolved] (KAFKA-7763) KafkaProducer with transactionId endless waits when network is disconnection for 10-20s

[ https://issues.apache.org/jira/browse/KAFKA-7763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-7763. Resolution: Fixed Fix Version/s: 2.3.0 > KafkaProducer with transactionId endless wa

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

See Changes: [wangguoz] KAFKA-6161 Add default implementation to close() and configure() for -- [...truncated 2.31 MB...] org.apache.kafka.connect.data.ConnectSchemaTest

Re: [DISCUSS] KIP-236 Interruptible Partition Reassignment

Thanks George. LGTM. Jun & Tom, Can you please take a look at the updated KIP. Thanks, Harsha On Wed, Feb 20, 2019, at 12:18 PM, George Li wrote: > Hi, > > After discussing with Tom, Harsha and I are picking up KIP-236 >

Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder

Great thank you Guozhang! We got 3 binding votes for KIP-300. I will close this thread and work on the implementations, thanks Matthias, Bill and Guozhang! Get Outlook for iOS From: Guozhang Wang Sent: Thursday, February 21, 2019 11:17 AM

Re: [VOTE] KIP-430 - Return Authorized Operations in Describe Responses

+1 (binding). Thanks, Harsha On Thu, Feb 21, 2019, at 2:49 AM, Satish Duggana wrote: > Thanks for the KIP, +1 (non-binding) > > ~Satish. > > On Thu, Feb 21, 2019 at 3:58 PM Rajini Sivaram > wrote: > > > > I would like to start vote on KIP-430 to optionally obtain authorized > > operations whe

[jira] [Created] (KAFKA-7973) Allow a Punctuator to cancel its own schedule

Matthias J. Sax created KAFKA-7973: -- Summary: Allow a Punctuator to cancel its own schedule Key: KAFKA-7973 URL: https://issues.apache.org/jira/browse/KAFKA-7973 Project: Kafka Issue Type: I

Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder

Thanks for the update Boyang. +1 from me (binding). Guozhang On Thu, Feb 21, 2019 at 11:08 AM Boyang Chen wrote: > Thank you so much Bill! > > Get Outlook for iOS > > > From: Bill Bejeck > Sent: Thursday, February 21, 2019 10:45 AM > To:

Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder

Thank you so much Bill! Get Outlook for iOS From: Bill Bejeck Sent: Thursday, February 21, 2019 10:45 AM To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder Thanks for the KIP Boyang. +1(binding

Re: [DISCUSS] KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

My gut says a building block that takes a configuration as input and exposes a representation of the potential issues found would be a good starting point. Then this could be leveraged as part of a command line tool that emits the data to stdout, or it could be used during broker startup such that

Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder

Thanks for the KIP Boyang. +1(binding) -Bill On Thu, Feb 21, 2019 at 12:31 PM Boyang Chen wrote: > Oh, good catch Guozhang. I just renamed the function to `sessionedTable` > to be consistent, thanks! > > > From: Guozhang Wang > Sent: Friday, February 22, 2019 1

Re: [DISCUSS] KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

I think that is a solid idea. The closest thing I can think of is David's PR about duplicate config key logging - https://github.com/apache/kafka/pull/6104 We could either continue the pattern of checking on broker startup and logging a warning or create a separate tool that analyzes the configs.

Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder

Oh, good catch Guozhang. I just renamed the function to `sessionedTable` to be consistent, thanks! From: Guozhang Wang Sent: Friday, February 22, 2019 1:12 AM To: dev Subject: Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder Hi Boyang, One quick qu

Re: [VOTE] KIP-300: Add Windowed KTable API in StreamsBuilder

Hi Boyang, One quick question: for time windowed tables the API signature is " windowedTable" while for session windowed tables the signature is " sessionTable", which seems inconsistent (adj. v.s. noun). WDYT? Guozhang On Wed, Feb 20, 2019 at 6:56 PM Matthias J. Sax wrote: > Thanks for the K

[jira] [Resolved] (KAFKA-6161) Add default implementation to close() and configure() for Serializer, Deserializer and Serde

[ https://issues.apache.org/jira/browse/KAFKA-6161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6161. -- Resolution: Fixed Fix Version/s: 2.3.0 > Add default implementation to close() and confi

[jira] [Created] (KAFKA-7972) Replace SaslHandshake request/response with automated protocol

Mickael Maison created KAFKA-7972: - Summary: Replace SaslHandshake request/response with automated protocol Key: KAFKA-7972 URL: https://issues.apache.org/jira/browse/KAFKA-7972 Project: Kafka

Re: [DISCUSS] KIP-411: Add option to make Kafka Connect task client ID values unique

Hi, Paul. Thanks for the update to KIP-411 to reflect adding defaults, and creating/updating https://github.com/apache/kafka/pull/6097 to reflect this approach. Now that we've avoided adding a new config and have changed the default ` client.id` to include some context, the connector name, and tas

Re: [DISCUSS] KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

Hi Ron, Yes, a security sanity check tool could be quite useful. Let's see what others think. Thanks, Rajini On Thu, Feb 21, 2019 at 1:49 PM Ron Dagostino wrote: > HI Rajini and Stan. Thanks for the feedback. > > Stan, regarding the proposed config name, I couldn't think of anything so I >

[jira] [Created] (KAFKA-7971) Producer in Streams environment

Maciej Lizewski created KAFKA-7971: -- Summary: Producer in Streams environment Key: KAFKA-7971 URL: https://issues.apache.org/jira/browse/KAFKA-7971 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-7970) Missing topic causes service shutdown without exception

Jonny Heavey created KAFKA-7970: --- Summary: Missing topic causes service shutdown without exception Key: KAFKA-7970 URL: https://issues.apache.org/jira/browse/KAFKA-7970 Project: Kafka Issue Typ

Re: [ANNOUNCE] New Committer: Randall Hauch

Thanks, everyone! On Sun, Feb 17, 2019 at 8:57 PM Becket Qin wrote: > Congratulations, Randall! > > On Sat, Feb 16, 2019 at 2:44 AM Matthias J. Sax > wrote: > > > Congrats Randall! > > > > > > -Matthias > > > > On 2/14/19 6:16 PM, Guozhang Wang wrote: > > > Hello all, > > > > > > The PMC of Apa

Jenkins build is back to normal : kafka-trunk-jdk8 #3404

See

Re: [DISCUSS] KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

HI Rajini and Stan. Thanks for the feedback. Stan, regarding the proposed config name, I couldn't think of anything so I just threw in something outrageous in the hopes that it would give a sense of what I was talking about while perhaps making folks chuckle a bit. Rajini, I definitely see your

Re: [DISCUSS] KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

Hi Ron, Thanks for the KIP. How is this different from other scenarios: 1. Our default is to use a PLAINTEXT listener. If you forget to change that, anyone has access to your cluster 2. You may add a PLAINTEXT listener to the list of listeners in production. May be you intended it for

Re: [DISCUSS] KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

Hey Ron, thanks for the KIP. I believe the proposed configuration setting `yes.virginia.i.really.do.want.to.allow.unsecured.oauthbearer.tokens.because.this.is.not.a.production.cluster` might be too verbose. I acknowledge that we do not want to enable this in production but we could maybe compromis

Re: [VOTE] KIP-430 - Return Authorized Operations in Describe Responses

Thanks for the KIP, +1 (non-binding) ~Satish. On Thu, Feb 21, 2019 at 3:58 PM Rajini Sivaram wrote: > > I would like to start vote on KIP-430 to optionally obtain authorized > operations when describing resources: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-430+-+Return+Authorized+

[VOTE] KIP-430 - Return Authorized Operations in Describe Responses

I would like to start vote on KIP-430 to optionally obtain authorized operations when describing resources: https://cwiki.apache.org/confluence/display/KAFKA/KIP-430+-+Return+Authorized+Operations+in+Describe+Responses Thank you, Rajini

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

See Changes: [junrao] KAFKA-7283: Enable lazy mmap on index files and skip sanity check for -- [...truncated 4.61 MB...] org.apache.kafka.streams.scala.StreamToTableJoinS

Re: [VOTE] KIP-412: Extend Admin API to support dynamic application log levels

Thanks for the interest everybody. This KIP has passed with 3 binding votes (Harsha, Gwen, Rajini) and 5 non-binding votes (Mickael, Jonathan, Dongjin, Satish, Andrew) On Thu, Feb 21, 2019 at 9:00 AM Satish Duggana wrote: > Thanks for the KIP > +1 (non-binding) > > On Thu, Feb 21, 2019 at 9:38

[jira] [Resolved] (KAFKA-7968) Delete leader epoch cache files with old message format versions

[ https://issues.apache.org/jira/browse/KAFKA-7968?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski resolved KAFKA-7968. Resolution: Duplicate This is a duplicate of https://issues.apache.org/jira/browse/

Re: [VOTE] KIP-412: Extend Admin API to support dynamic application log levels

Thanks for the KIP +1 (non-binding) On Thu, Feb 21, 2019 at 9:38 AM Harsha wrote: > > +1 (binding). > > Thanks, > Harsha > > On Tue, Feb 19, 2019, at 7:53 AM, Andrew Schofield wrote: > > Thanks for the KIP. > > > > +1 (non-binding) > > > > On 18/02/2019, 12:48, "Stanislav Kozlovski" wrote: > >

[jira] [Created] (KAFKA-7969) Flaky Test DescribeConsumerGroupTest#testDescribeOffsetsOfExistingGroupWithNoMembers

Matthias J. Sax created KAFKA-7969: -- Summary: Flaky Test DescribeConsumerGroupTest#testDescribeOffsetsOfExistingGroupWithNoMembers Key: KAFKA-7969 URL: https://issues.apache.org/jira/browse/KAFKA-7969

Re: [DISCUSS] KIP-378: Enable Dependency Injection for Kafka Streams handlers

Hi Wladimir, what is the status of this KIP? -Matthias On 1/9/19 4:17 PM, Guozhang Wang wrote: > Hello Wladimir, > > Just checking if you are still working on this KIP. We have the 2.2 KIP > freeze deadline by 24th this month, and it'll be great to complete this KIP > by then so 2.2.0 release c

Jenkins build is back to normal : kafka-trunk-jdk11 #302

See

[jira] [Created] (KAFKA-7968) Delete leader epoch cache files with old message format versions

Stanislav Kozlovski created KAFKA-7968: -- Summary: Delete leader epoch cache files with old message format versions Key: KAFKA-7968 URL: https://issues.apache.org/jira/browse/KAFKA-7968 Project: K