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

See

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

See

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Hm, the case of `all()` does seem to present a dilemma in the case of variable-length keys. In the case of fixed-length keys, you can just compute the keys that correspond to the maximum and minimum serialized bytes, then perform a `range()` query instead of an `all()`. If your keys don't have a

Build failed in Jenkins: kafka-trunk-jdk14 #116

See Changes: [github] KAFKA-9980: Fix bug where alterClientQuotas could not set default client -- [...truncated 3.10 MB...]

Re: Want to remove the archive

Hi Satya, I think Matthias had replied your mail on 5/11. Please check it here: https://lists.apache.org/thread.html/r6bd3cf8f092accdf59c4b5b878d62faaa1a9de074b31ecf4cb7a0b64%40%3Cdev.kafka.apache.org%3E Thanks. On Wed, May 20, 2020 at 9:08 PM Satya Kotni wrote: > Any update on this? > >

[jira] [Resolved] (KAFKA-9942) ConfigCommand fails to set client quotas for default users with --bootstrap-server.

[ https://issues.apache.org/jira/browse/KAFKA-9942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-9942. - Fix Version/s: 2.5.1 2.6.0 Resolution: Fixed > ConfigCommand fails to

[jira] [Resolved] (KAFKA-9980) Fix bug where alterClientQuotas could not set default client quotas

[ https://issues.apache.org/jira/browse/KAFKA-9980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe resolved KAFKA-9980. - Fix Version/s: 2.5.1 Resolution: Fixed > Fix bug where alterClientQuotas could not set

Re: [VOTE] KIP-612: Ability to Limit Connection Creation Rate on Brokers

The vote for KIP-612 has passed with 3 binding and 3 non-binding +1s, and no objections. Thanks everyone for reviews and feedback, Anna On Tue, May 19, 2020 at 2:41 AM Rajini Sivaram wrote: > +1 (binding) > > Thanks for the KIP, Anna! > > Regards, > > Rajini > > > On Tue, May 19, 2020 at

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Thanks John. Agree. I like the first approach as well, with StreamsConfig flag passing by via ProcessorContext. Another positive effect with "reverse parameters" is that in the case of `fetch(keyFrom, keyTo, timeFrom, timeTo)` users can decide _which_ pair to flip, whether with `ReadDirection`

Build failed in Jenkins: kafka-trunk-jdk14 #115

See Changes: [github] KAFKA-9780: Deprecate commit records without record metadata (#8379) -- [...truncated 377.20 KB...]

Build failed in Jenkins: kafka-2.5-jdk8 #129

See Changes: [rhauch] MINOR: Correct MirrorMaker2 integration test configs for Connect -- [...truncated 2.10 MB...]

Build failed in Jenkins: kafka-trunk-jdk14 #114

See Changes: [github] MINOR: Deploy VerifiableClient in constructor to avoid test timeouts -- [...truncated 5.06 MB...]

Build failed in Jenkins: kafka-2.4-jdk8 #213

See Changes: [rhauch] MINOR: Correct MirrorMaker2 integration test configs for Connect -- [...truncated 2.29 MB...] kafka.api.SaslSslAdminClientIntegrationTest >

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

See Changes: [github] KAFKA-9780: Deprecate commit records without record metadata (#8379) -- [...truncated 1.79 MB...] kafka.server.epoch.LeaderEpochFileCacheTest >

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

See Changes: [github] KAFKA-9780: Deprecate commit records without record metadata (#8379) -- [...truncated 2.11 MB...]

Re: [DISCUSS] KIP-602 - Change default value for client.dns.lookup

Badai, would you like to start a vote on this KIP? Ismael On Wed, May 20, 2020 at 7:45 AM Rajini Sivaram wrote: > Deprecating for removal in 3.0 sounds good. > > On Wed, May 20, 2020 at 3:33 PM Ismael Juma wrote: > > > Is there any reason to use "use_first_dns_ip"? Should we remove it > >

Re: [DISCUSS] KIP-573: Enable TLSv1.3 by default

Ismael, thanks for the clarification. I updated the KIP according to your proposal. > 21 мая 2020 г., в 17:06, Ismael Juma написал(а): > > Given what we've seen in the test, it would be good to mention that TLS 1.3 > will not work for users who have configured ciphers explicitly. If such >

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

See Changes: [github] MINOR: Deploy VerifiableClient in constructor to avoid test timeouts -- [...truncated 3.10 MB...] org.apache.kafka.streams.TestTopicsTest >

Re: [VOTE] KIP-573: Enable TLSv1.3 by default

Thanks everyone! After 3+ business days since this thread started, I'm concluding the vote on KIP-573. The KIP has passed with: 3 binding votes from Ismael Juma, Rajini Sivaram, Manikumar. Thank you all for voting! > 21 мая 2020 г., в 19:50, Ismael Juma написал(а): > > Nikolay, you have

[jira] [Resolved] (KAFKA-9780) Deprecate commit records without record metadata

[ https://issues.apache.org/jira/browse/KAFKA-9780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9780. -- Reviewer: Randall Hauch Resolution: Fixed Merged to `trunk` after

Re: [VOTE] KIP-589: Add API to update Replica state in Controller

+1. LGTM David! On Wed, May 20, 2020 at 12:22 PM David Arthur wrote: > > Hello, all. I'd like to start the vote for KIP-589 which proposes to add a > new AlterReplicaState RPC. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-589+Add+API+to+update+Replica+state+in+Controller > > Cheers,

Re: [VOTE] KIP-610: Error Reporting in Sink Connectors

The vote has been open for >72 hours, and the KIP is adopted with three +1 binding votes (Konstantine, Ewen, me), one +1 non-binding vote (Andrew), and no -1 votes. I'll update the KIP and the AK 2.6.0 plan. Thanks, everyone. On Tue, May 19, 2020 at 4:33 PM Konstantine Karantasis <

Re: [DISCUSS] KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

Thanks David, I agree the wording here is not clear, and the fellow broker should just send a new CreateTopicRequest in this case. In the meantime, we had some offline discussion about the Envelope API as well. Although it provides certain privileges like data embedding and principal embedding,

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

See Changes: [github] MINOR: Added unit tests for ConnectionQuotas (#8650) [github] MINOR: Deploy VerifiableClient in constructor to avoid test timeouts --

Build failed in Jenkins: kafka-trunk-jdk14 #113

See Changes: [github] MINOR: Correct MirrorMaker2 integration test configs for Connect [github] MINOR: Added unit tests for ConnectionQuotas (#8650) -- [...truncated

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

See Changes: [github] MINOR: Correct MirrorMaker2 integration test configs for Connect [github] MINOR: Added unit tests for ConnectionQuotas (#8650) -- [...truncated

Re: [VOTE] KIP-573: Enable TLSv1.3 by default

Nikolay, you have enough votes and 72 hours have passed, so you can close this vote as successful whenever you're ready. Ismael On Mon, Mar 2, 2020 at 10:55 AM Nikolay Izhikov wrote: > Hello. > > I would like to start vote for KIP-573: Enable TLSv1.3 by default > > KIP - >

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

See Changes: [github] MINOR: Correct MirrorMaker2 integration test configs for Connect -- [...truncated 1.44 MB...] kafka.api.PlaintextAdminIntegrationTest >

Re: [VOTE] KIP-545 support automated consumer offset sync across clusters in MM 2.0

+1 (binding). Good addition to MM 2. -Harsha On Thu, May 21, 2020 at 8:36 AM, Manikumar < manikumar.re...@gmail.com > wrote: > > > > +1 (binding). > > > > Thanks for the KIP. > > > > On Thu, May 21, 2020 at 9:49 AM Maulin Vasavada < maulin. vasavada@ gmail. > com (

Re: [VOTE] KIP-545 support automated consumer offset sync across clusters in MM 2.0

+1 (binding). Thanks for the KIP. On Thu, May 21, 2020 at 9:49 AM Maulin Vasavada wrote: > Thank you for the KIP. I sincerely hope we get enough votes on this KIP. I > was thinking of similar changes while working on DR capabilities and > offsets are Achilles Heels and this KIP addresses it. >

Re: [VOTE] KIP-573: Enable TLSv1.3 by default

+1 (binding) Thanks for the KIP. On Thu, May 21, 2020 at 7:42 PM Rajini Sivaram wrote: > +1 (binding) > > Thanks for the KIP, Nikolay! > > Regards, > > Rajini > > > On Thu, May 21, 2020 at 3:04 PM Ismael Juma wrote: > > > Thanks for the KIP, +1 (binding) > > > > On Mon, Mar 2, 2020 at 10:55

Re: [VOTE]: KIP-604: Remove ZooKeeper Flags from the Administrative Tools

Hi all, With 4 binding +1 votes from Guozhang Wang, Manikumar, Mickael Miason, and Jason Gustafson, and 1 non-binding vote from David Jacot, the vote passes. thanks, all. Colin On Wed, May 20, 2020, at 18:16, Jason Gustafson wrote: > Sounds good. +1 from me. > > On Tue, May 19, 2020 at 5:41

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Hi Jorge, Thanks for that idea. I agree, a feature flag would protect anyone who may be depending on the current behavior. It seems better to locate the feature flag in the initialization logic of the store, rather than have a method on the "live" store that changes its behavior on the fly. It

Re: [VOTE] KIP-573: Enable TLSv1.3 by default

+1 (binding) Thanks for the KIP, Nikolay! Regards, Rajini On Thu, May 21, 2020 at 3:04 PM Ismael Juma wrote: > Thanks for the KIP, +1 (binding) > > On Mon, Mar 2, 2020 at 10:55 AM Nikolay Izhikov > wrote: > > > Hello. > > > > I would like to start vote for KIP-573: Enable TLSv1.3 by

Re: [DISCUSS] KIP-573: Enable TLSv1.3 by default

Given what we've seen in the test, it would be good to mention that TLS 1.3 will not work for users who have configured ciphers explicitly. If such users want to use TLS 1.3, they will have to update the list of ciphers to include TLS 1.3 ciphers (which use a different naming convention). TLS 1.2

Re: [VOTE] KIP-573: Enable TLSv1.3 by default

Thanks for the KIP, +1 (binding) On Mon, Mar 2, 2020 at 10:55 AM Nikolay Izhikov wrote: > Hello. > > I would like to start vote for KIP-573: Enable TLSv1.3 by default > > KIP - > https://cwiki.apache.org/confluence/display/KAFKA/KIP-573%3A+Enable+TLSv1.3+by+default > Discussion thread - >

[jira] [Created] (KAFKA-10030) Throw exception while fetching a key from a single partition

Dima R created KAFKA-10030: -- Summary: Throw exception while fetching a key from a single partition Key: KAFKA-10030 URL: https://issues.apache.org/jira/browse/KAFKA-10030 Project: Kafka Issue

Re: [DISCUSSION] KIP-418: A method-chaining way to branch KStream

Hi, Thanks Matthias for your suggestion: yes, I agree that getting rid of `with[Java]Consumer` makes this thing 'as simple as possible, but not simpler'. I made some quick API mocking in my IDE and tried to implement examples from KIP. 1. Having to return something from lambda is not a

[jira] [Created] (KAFKA-10029) Selector.completedReceives should not be modified when channel is closed

Rajini Sivaram created KAFKA-10029: -- Summary: Selector.completedReceives should not be modified when channel is closed Key: KAFKA-10029 URL: https://issues.apache.org/jira/browse/KAFKA-10029

[jira] [Created] (KAFKA-10028) KIP-584: Implement write path for versioning scheme for features

Kowshik Prakasam created KAFKA-10028: Summary: KIP-584: Implement write path for versioning scheme for features Key: KAFKA-10028 URL: https://issues.apache.org/jira/browse/KAFKA-10028 Project:

Build failed in Jenkins: kafka-2.4-jdk8 #212

See Changes: [konstantine] KAFKA-9950: Construct new ConfigDef for MirrorTaskConfig before defining -- [...truncated 27.51 KB...]

Build failed in Jenkins: kafka-2.5-jdk8 #128

See Changes: [konstantine] KAFKA-9950: Construct new ConfigDef for MirrorTaskConfig before defining -- Started by an SCM change Started by an SCM change Running as SYSTEM

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

See Changes: [github] KAFKA-8869: Remove task configs for deleted connectors from config [github] KAFKA-9950: Construct new ConfigDef for MirrorTaskConfig before defining [github] KAFKA-9855 - return cached

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

See Changes: [github] KAFKA-9950: Construct new ConfigDef for MirrorTaskConfig before defining [github] KAFKA-9855 - return cached Structs for Schemas with no fields (#8472)

Build failed in Jenkins: kafka-2.5-jdk8 #127

See Changes: [konstantine] KAFKA-8869: Remove task configs for deleted connectors from config -- [...truncated 1.83 MB...] kafka.security.authorizer.AclAuthorizerTest >

Build failed in Jenkins: kafka-2.3-jdk8 #203

See Changes: [konstantine] KAFKA-8869: Remove task configs for deleted connectors from config -- [...truncated 2.24 MB...] kafka.log.LogSegmentTest >

Build failed in Jenkins: kafka-trunk-jdk14 #112

See Changes: [github] KAFKA-9950: Construct new ConfigDef for MirrorTaskConfig before defining [github] KAFKA-9855 - return cached Structs for Schemas with no fields (#8472)

Build failed in Jenkins: kafka-2.4-jdk8 #211

See Changes: [konstantine] KAFKA-8869: Remove task configs for deleted connectors from config -- [...truncated 2.26 MB...] kafka.api.SslEndToEndAuthorizationTest >

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

See Changes: [github] KAFKA-9409: Supplement immutability of ClusterConfigState class in [github] KAFKA-8869: Remove task configs for deleted connectors from config --

Build failed in Jenkins: kafka-trunk-jdk14 #111

See Changes: [github] KAFKA-9409: Supplement immutability of ClusterConfigState class in [github] KAFKA-8869: Remove task configs for deleted connectors from config --