Re: [DISCUSS] KIP-480 : Sticky Partitioner

Thanks for the comments Colin. My only concern is that this KIP is addressing a good feature and having that extended to RoundRobinPartitioner means 1 less KIP in the future. Would it be appropriate to extend the support to RoundRobinPartitioner too? Thanks, On Tue, 9 Jul 2019 at 17:24, Colin M

[jira] [Created] (KAFKA-8646) Materialized.withLoggingDisabled() does not disable the changelog topics creation

jmhostalet created KAFKA-8646: - Summary: Materialized.withLoggingDisabled() does not disable the changelog topics creation Key: KAFKA-8646 URL: https://issues.apache.org/jira/browse/KAFKA-8646 Project: Ka

[jira] [Created] (KAFKA-8647) Add consumer-props option to match producer-props for console consumer

Antony Stubbs created KAFKA-8647: Summary: Add consumer-props option to match producer-props for console consumer Key: KAFKA-8647 URL: https://issues.apache.org/jira/browse/KAFKA-8647 Project: Kafka

[jira] [Created] (KAFKA-8648) Console tools should fail fast if an unrecognised option is passed in

Antony Stubbs created KAFKA-8648: Summary: Console tools should fail fast if an unrecognised option is passed in Key: KAFKA-8648 URL: https://issues.apache.org/jira/browse/KAFKA-8648 Project: Kafka

PR feedback request

Hello, Looking to get some reviews for KAFKA-8526 - Broker may select a failed dir for new replica even in the presence of other live dirs https://github.com/apache/kafka/pull/6969 https://issues.apache.org/jira/browse/KAFKA-8526 Thanks, -- Igor Soarez

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

See Changes: [jason] KAFKA-8636; Add documentation change for max poll interval with static -- [...truncated 6.47 MB...] org.apache.kafka.streams.KafkaStreamsTest > shou

Re: [DISCUSS] KIP-480 : Sticky Partitioner

Hi M, I'm a little confused by what you mean by extending the behavior on to the RoundRobinPartitioner. The sticky partitioner plans to remove the round-robin behavior from records with no keys. Instead of sending them to each partition in order, it sends them all to the same partition until the b

Re: [DISCUSS] KIP-466: Add support for List serialization and deserialization

Hi John, Yes, I do agree. That totally makes sense. The only thing is that it goes against what Matthias suggested earlier: "I think that ... `ListSerde` should have an default constructor and it should be possible to pass in the `Class listClass` information via a configuration. Otherwise, Kaf

Re: [DISCUSS] KIP-213: Second follow-up on Foreign Key Joins

Hey Matthias and Adam, I've been mulling over your recent conversation. I'll share my two cents... - First (because it's always best to get the semantics clear before the details): Extra tombstones do NOT harm the semantics of an inner join. The difference between a left join and an inner joi

[jira] [Created] (KAFKA-8649) Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0

Suyash Garg created KAFKA-8649: -- Summary: Error while rolling update from Kafka Streams 2.0.0 -> Kafka Streams 2.1.0 Key: KAFKA-8649 URL: https://issues.apache.org/jira/browse/KAFKA-8649 Project: Kafka

[jira] [Created] (KAFKA-8650) Streams does not work as expected with auto.offset.reset=none

Raman Gupta created KAFKA-8650: -- Summary: Streams does not work as expected with auto.offset.reset=none Key: KAFKA-8650 URL: https://issues.apache.org/jira/browse/KAFKA-8650 Project: Kafka Issu

Re: [DISCUSS] KIP-213: Second follow-up on Foreign Key Joins

Hi John Excellent post! I greatly appreciate your insight (and XKCD reference). I think you've hit it on the head. I was mostly concerned with the semantics of having a true INNER join where no unnecessary tombstones are emitted. As you point out though, the semantics are not the issue, it is the

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

See Changes: [jason] KAFKA-8636; Add documentation change for max poll interval with static -- [...truncated 9.14 MB...] org.apache.kafka.connect.json.JsonConverterTest >

[jira] [Created] (KAFKA-8651) Add a #branch overload that takes a Map of predicate names to predicates

Antony Stubbs created KAFKA-8651: Summary: Add a #branch overload that takes a Map of predicate names to predicates Key: KAFKA-8651 URL: https://issues.apache.org/jira/browse/KAFKA-8651 Project: Kafka

Request access to create a KIP

Hi, I'd like permission to create a new KIP page in the wiki. Confluence username: sean.glover Regards, Sean -- Principal Engineer, Lightbend, Inc. @seg1o , in/seanaglover

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

See Changes: [github] MINOR: Only invoke hw update logic for follower fetches (#7064) -- [...truncated 2.56 MB...] > Task :connect:runtime:test FAILED > Task :generator:t

[jira] [Created] (KAFKA-8652) Jenkins stop triggering tests for prs since 07/10

Boyang Chen created KAFKA-8652: -- Summary: Jenkins stop triggering tests for prs since 07/10 Key: KAFKA-8652 URL: https://issues.apache.org/jira/browse/KAFKA-8652 Project: Kafka Issue Type: Bug

CVE-2018-17196: Potential to bypass transaction/idempotent ACL checks in Apache Kafka

CVE-2018-17196: Potential to bypass transaction/idempotent ACL checks in Apache Kafka Severity: Moderate Vendor: The Apache Software Foundation Versions Affected: Apache Kafka 0.11.0.0 - 2.1.0 Description: It is possible to manually craft a Produce request which bypasses transaction/idempotent

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

See Changes: [github] MINOR: Only invoke hw update logic for follower fetches (#7064) [github] KAFKA-8634: Update ZooKeeper to 3.5.5 (#6802) -- [...truncated 6.57 MB...]

[jira] [Resolved] (KAFKA-8636) Document behavior change for static members with `max.poll.interval.ms`

[ https://issues.apache.org/jira/browse/KAFKA-8636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-8636. Resolution: Fixed > Document behavior change for static members with `max.poll.interval.ms` > -

PR builds stopped since 07/10 11AM

Hey there, just want you to be aware that all the Jenkins PR builds are stopped since today's morning: https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/ https://builds.apache.org/job/kafka-pr-jdk11-scala2.12/ I have filed two JIRAs https://issues.apache.org/jira/browse/INFRATEST1-10 and ht

[jira] [Created] (KAFKA-8653) Regression in JoinGroup v0 rebalance timeout handling

Jason Gustafson created KAFKA-8653: -- Summary: Regression in JoinGroup v0 rebalance timeout handling Key: KAFKA-8653 URL: https://issues.apache.org/jira/browse/KAFKA-8653 Project: Kafka Issue

Re: PR builds stopped since 07/10 11AM

Hi Boyang, An INFRA JIRA is the right way to proceed here. Unfortunately none of the JIRAs below are for the right project. Ismael On Wed, Jul 10, 2019, 5:09 PM Boyang Chen wrote: > Hey there, > > just want you to be aware that all the Jenkins PR builds are stopped since > today's morning: > h

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

See

Re: PR builds stopped since 07/10 11AM

I was reading the Apache Builds mailing list and: as part of some cleanup and consolidation (essentially we don't want to > maintain two different plugins that do the same thing), we have removed > support for the old GitHub PR Builder on Jenkins, and are focusing on the > modern variant. If your

Re: PR builds stopped since 07/10 11AM

Thanks a lot Ismael for the help here! On Wed, Jul 10, 2019 at 7:30 PM Ismael Juma wrote: > I was reading the Apache Builds mailing list and: > > as part of some cleanup and consolidation (essentially we don't want to > > maintain two different plugins that do the same thing), we have removed >

Re: Request access to create a KIP

Done. On 7/10/19 12:18 PM, Sean Glover wrote: > Hi, > > I'd like permission to create a new KIP page in the wiki. Confluence > username: sean.glover > > Regards, > Sean > signature.asc Description: OpenPGP digital signature