Re: [ANNOUNCE] Apache Kafka 2.2.0

Congratulations for the 2.2.0 release! Regards, Sanjeev On Wed, Mar 27, 2019 at 6:43 AM Guozhang Wang wrote: > Thanks Matthias for the release! > > On Tue, Mar 26, 2019 at 9:31 PM Dongjin Lee wrote: > > > Congratulations and thanks for your great work, Matthias!! > > > > Best, > > Dongjin > >

Re: [ANNOUNCE] Apache Kafka 2.2.0

Thanks Matthias for the release! On Tue, Mar 26, 2019 at 9:31 PM Dongjin Lee wrote: > Congratulations and thanks for your great work, Matthias!! > > Best, > Dongjin > > On Wed, Mar 27, 2019 at 4:49 AM Stephane Maarek > > wrote: > > > Congratulations on this amazing release! Lots of cool new fea

Re: [ANNOUNCE] Apache Kafka 2.2.0

Congratulations and thanks for your great work, Matthias!! Best, Dongjin On Wed, Mar 27, 2019 at 4:49 AM Stephane Maarek wrote: > Congratulations on this amazing release! Lots of cool new features :) > > I've also released a YouTube video that will hopefully help the community > get up to speed

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

See Changes: [github] KAFKA-3522: Add RocksDBTimestampedSegmentedBytesStore (#6186) -- [...truncated 4.71 MB...] org.apache.kafka.streams.test.OutputVerifierTest > should

Re: [VOTE] KIP-392: Allow consumers to fetch from the closest replica

Hi, Jason, Thanks for the KIP. Just a couple of more comments. 200. I am wondering if we really need the replica.selection.policy config in the consumer. A slight variant is that we (1) let the consumer always fetch from the PreferredReplica and (2) provide a default implementation of ReplicaSele

Re: [DISCUSS] KIP-433: Provide client API version to authorizer

I have rewritten the KIP. The new proposal is adding a new configuration min.api.version in Kafka broker. Please review the new KIP. Thank you! On Fri, Mar 1, 2019 at 11:06 AM Colin McCabe wrote: > On Wed, Feb 27, 2019, at 15:53, Harsha wrote: > > HI Colin, > > Overlooked the IDEMPO

[jira] [Created] (KAFKA-8160) To add ACL with SSL authentication

suseendramani created KAFKA-8160: Summary: To add ACL with SSL authentication Key: KAFKA-8160 URL: https://issues.apache.org/jira/browse/KAFKA-8160 Project: Kafka Issue Type: New Feature

Re: [DISCUSS] KIP-236 Interruptible Partition Reassignment

Hi Ismael, Thanks,  I understand your points. I will add the RPC mechanism for reassignments to KIP-236.  I can think of a few Requests/Responses corresponding to the old Scala AdminClient using ZK:   SubmitReassignments (--execute) StatusReassignments (--verify) ChangeOrRemoveReassignmentsThr

[jira] [Created] (KAFKA-8159) Multi-key range queries with negative keyFrom results in unexpected behavior

Sophie Blee-Goldman created KAFKA-8159: -- Summary: Multi-key range queries with negative keyFrom results in unexpected behavior Key: KAFKA-8159 URL: https://issues.apache.org/jira/browse/KAFKA-8159

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

See Changes: [matthias] MINOR: Add 2.2.0 upgrade instructions (#6501) -- [...truncated 2.73 MB...] kafka.controller.PartitionLeaderElectionAlgorithmsTest > testReassignPartit

[jira] [Created] (KAFKA-8158) Add EntityType for Kafka RPC fields

Colin P. McCabe created KAFKA-8158: -- Summary: Add EntityType for Kafka RPC fields Key: KAFKA-8158 URL: https://issues.apache.org/jira/browse/KAFKA-8158 Project: Kafka Issue Type: Improvement

Build failed in Jenkins: kafka-0.11.0-jdk7 #414

See Changes: [github] MINOR: fix flaky QueryableStateIntegrationTest (#6458) -- [...truncated 1.55 MB...] org.apache.kafka.streams.integration.QueryableStateIntegrationTe

Re: [ANNOUNCE] Apache Kafka 2.2.0

Congratulations on this amazing release! Lots of cool new features :) I've also released a YouTube video that will hopefully help the community get up to speed: https://www.youtube.com/watch?v=kaWbp1Cnfo4&t=5s Happy watching! On Tue, Mar 26, 2019 at 7:02 PM Matthias J. Sax wrote: > The Apache

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

See Changes: [github] MINOR: Add 2.2.0 upgrade instructions (#6501) -- [...truncated 2.34 MB...] org.apache.kafka.connect.converters.FloatConverterTest > testSerializingI

[jira] [Reopened] (KAFKA-1149) Please delete old releases from mirroring system

[ https://issues.apache.org/jira/browse/KAFKA-1149?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sebb reopened KAFKA-1149: - There are now 9 releases on the mirrors. Please respect the 3rd party mirrors and remove all non-current releases.

[ANNOUNCE] Apache Kafka 2.2.0

The Apache Kafka community is pleased to announce the release for Apache Kafka 2.2.0 - Added SSL support for custom principal name - Allow SASL connections to periodically re-authenticate - Command line tool bin/kafka-topics.sh adds AdminClient support - Improved consumer group management -

Re: [DISCUSS] KIP-429 : Smooth Auto-Scaling for Kafka Streams

Sounds good Guozhang! I will kick another discussion thread for KIP-444. Boyang From: Guozhang Wang Sent: Thursday, March 21, 2019 9:17 AM To: dev Subject: Re: [DISCUSS] KIP-429 : Smooth Auto-Scaling for Kafka Streams Hello Boyang, I've made another thorough pa

Re: [VOTE] KIP-392: Allow consumers to fetch from the closest replica

It's going to change quite a few things for learners, but this is an awesome idea! +1 (non-binding) On Tue, Mar 26, 2019 at 3:35 PM Viktor Somogyi-Vass wrote: > +1 (non-binding) very good proposal. > > On Mon, Mar 25, 2019 at 7:19 PM David Arthur wrote: > > > +1 > > > > Thanks, Jason! > > > > O

Re: [VOTE] KIP-392: Allow consumers to fetch from the closest replica

+1 (non-binding) very good proposal. On Mon, Mar 25, 2019 at 7:19 PM David Arthur wrote: > +1 > > Thanks, Jason! > > On Mon, Mar 25, 2019 at 1:23 PM Eno Thereska > wrote: > > > +1 (non-binding) > > Thanks for updating the KIP and addressing my previous comments. > > > > Eno > > > > On Mon, Mar

[jira] [Created] (KAFKA-8157) Missing "key.serializer" exception when setting "segment index bytes"

Cristian D created KAFKA-8157: - Summary: Missing "key.serializer" exception when setting "segment index bytes" Key: KAFKA-8157 URL: https://issues.apache.org/jira/browse/KAFKA-8157 Project: Kafka