Jenkins build is back to normal : Kafka » kafka-2.6-jdk8 #110

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #656

See Changes: [github] Initial commit (#10454) -- [...truncated 3.69 MB...] KafkaZkClientTest > testUpdateBrokerInfo() STARTED KafkaZkClientTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #688

See Changes: [github] Initial commit (#10454) -- [...truncated 3.69 MB...] AuthorizerIntegrationTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #627

See Changes: [github] Initial commit (#10454) -- [...truncated 3.67 MB...] LogValidatorTest > testUncompressedBatchWithoutRecordsNotAllowed() STARTED

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #655

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #687

See Changes: [github] KAFKA-12575: Eliminate Log.isLogDirOffline boolean attribute (#10430) -- [...truncated 3.69 MB...] KafkaZkClientTest >

Re: [DISCUSS] KIP-725: Streamlining configurations for TimeWindowedDeserializer.

Thanks Sagar! The KIP looks good to me now. Let's see what others think On Fri, Mar 26, 2021 at 1:36 AM Sagar wrote: > Hi Sophie, > > Thanks for the feedback! I have updated the KIP inline with whatever you > suggested. > > Regarding point 5, I have added the note as it makes sense to not set

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #626

See Changes: [github] KAFKA-12575: Eliminate Log.isLogDirOffline boolean attribute (#10430) -- [...truncated 3.68 MB...] TransactionsTest >

Re: [DISCUSS] KIP-633: Drop 24 hour default of grace period in Streams

Hello Sophie, I agree that the old 24-hour grace period should be updated, and I also think now it is a better idea to make the grace period "mandatory" from the API names since it is a very important concept and hence worth emphasizing to users up front. Guozhang On Wed, Mar 31, 2021 at 1:58

[jira] [Created] (KAFKA-12595) New Consumer metric for records/bytes committed

A. Sophie Blee-Goldman created KAFKA-12595: -- Summary: New Consumer metric for records/bytes committed Key: KAFKA-12595 URL: https://issues.apache.org/jira/browse/KAFKA-12595 Project: Kafka

[jira] [Created] (KAFKA-12594) Self-join produces no ouput, and prevents other streams from producing output

Jamie Brandon created KAFKA-12594: - Summary: Self-join produces no ouput, and prevents other streams from producing output Key: KAFKA-12594 URL: https://issues.apache.org/jira/browse/KAFKA-12594

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #654

See Changes: [github] KAFKA-8405; Remove deprecated `kafka-preferred-replica-election` command (#10443) -- [...truncated 7.39 MB...] KafkaZkClientTest >

Re: [VOTE] 2.6.2 RC0

Hi, > Can you clarify a few things? Sorry I'm not subscribed to this list and only just saw this. > - On the first point, the only thing I see is zstd, which we do not, in > fact, ship the library itself, just the jni bindings. Was there anything > else you saw? In the source release you are

[jira] [Resolved] (KAFKA-12575) Eliminate Log.isLogDirOffline boolean attribute

[ https://issues.apache.org/jira/browse/KAFKA-12575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-12575. - Fix Version/s: 3.0.0 Resolution: Fixed merged the PR to trunk > Eliminate Log.isLogDirOffline

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #625

See Changes: [github] KAFKA-8405; Remove deprecated `kafka-preferred-replica-election` command (#10443) -- [...truncated 3.67 MB...] LogValidatorTest >

Re: [DISCUSS] KIP-633: Drop 24 hour default of grace period in Streams

Thanks for bringing this up, Sophie! This has indeed been a pain point for a lot of people. It's a really thorny issue with no obvious "right" solution. I think your proposal is a good one. Thanks, -John On Wed, 2021-03-31 at 13:28 -0700, Sophie Blee-Goldman wrote: > Hey all, > > It's finally

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #686

See Changes: [github] MINOR: Fix docs for end-to-end record latency metrics (#10449) [github] KAFKA-8405; Remove deprecated `kafka-preferred-replica-election` command (#10443)

[DISCUSS] KIP-633: Drop 24 hour default of grace period in Streams

Hey all, It's finally time to reconsider the default grace period in Kafka Streams, and hopefully save a lot of suppression users from the pain of figuring out why their results don't show up until 24 hours later. Please check out the proposal and let me know what you think. KIP:

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #653

See Changes: [github] MINOR Replaced File with Path in LogSegmentData. (#10424) [github] MINOR: Fix docs for end-to-end record latency metrics (#10449) --

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #624

See Changes: [github] MINOR Replaced File with Path in LogSegmentData. (#10424) [github] MINOR: Fix docs for end-to-end record latency metrics (#10449) --

Re: [DISCUSS] KIP-726: Make the CooperativeStickyAssignor as the default assignor

Hi all, @Sophie - I like the sound of the dual-protocol default. The smooth upgrade path it permits sounds fantastic! @Luke - Do you think we can also include Connect in this KIP? Right now we don't set any custom partition assignment strategies for the consumer groups we bring up for sink

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #685

See Changes: [github] MINOR Replaced File with Path in LogSegmentData. (#10424) -- [...truncated 3.69 MB...] AclAuthorizerTest > testNoAclFoundOverride()

[jira] [Resolved] (KAFKA-8405) Remove deprecated `kafka-preferred-replica-election` command

[ https://issues.apache.org/jira/browse/KAFKA-8405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-8405. Reviewer: Ismael Juma Resolution: Fixed > Remove deprecated

Re: [kafka-clients] [VOTE] 2.6.2 RC0

Hey Georg, I'm currently working out the issues with the licensing that Justin brought up earlier along with the other release manager(s). I expect to be back on track with a new RC under vote by the beginning of next week. Here's the ticket for anyone interested in following along:

Re: [VOTE] 2.6.2 RC0

Hi Justin, Thanks for bringing this up and for your advice in resolving it. I've carved out the specific chunk of work relating to copyright, and wanted to call your attention to a specific proposal I have to fix this situation:

[jira] [Created] (KAFKA-12593) The Streams-Scala contains the wrong license header

John Roesler created KAFKA-12593: Summary: The Streams-Scala contains the wrong license header Key: KAFKA-12593 URL: https://issues.apache.org/jira/browse/KAFKA-12593 Project: Kafka Issue

RE: [kafka-clients] [VOTE] 2.6.2 RC0

Hi Sophie, Is there a new RC yet? Thanks for driving the release. Kind regards Georg -Original Message- From: Sophie Blee-Goldman Sent: Friday, March 19, 2021 11:44 PM To: Bruno Cadonna Cc: dev ; us...@kafka.apache.org; kafka-clie...@googlegroups.com Subject: Re: [kafka-clients]

Re: [DISCUSS] KIP-727 Add --under-preferred-replica-partitions option to describe topics command

Hi Tom, Thank you so much for your good suggestions. Based on your suggestions above, I've updated in the KIP-727. I used the following options for testing: *--non-preferred-leader *for the more human readable output. *--non-preferred-leader-json *for the JSON output would be used by

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #652

See Changes: [github] KAFKA-12583: Upgrade netty to 4.1.62.Final -- [...truncated 3.70 MB...] KafkaZkClientTest > testPropagateLogDir() STARTED

[jira] [Reopened] (KAFKA-9897) Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-9897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman reopened KAFKA-9897: --- > Flaky Test StoreQueryIntegrationTest#shouldQuerySpecificActivePartitionStores

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #623

See Changes: [github] KAFKA-12583: Upgrade netty to 4.1.62.Final -- [...truncated 3.67 MB...] TransactionsTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #684

See Changes: [github] KAFKA-12583: Upgrade netty to 4.1.62.Final -- [...truncated 3.69 MB...] AuthorizerIntegrationTest >

Re: [DISCUSS] KIP-712: Shallow Mirroring

Hi, Henry, Thanks for the KIP. Sorry for the late reply. A few comments below. 1. The 'shallow' feature is potentially useful. I do agree with Tom that the proposed API changes seem unclean. Quite a few existing stuff don't really work together with this (e.g., generics, serializer,

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

Hi Chia-Ping, Deprecating `send` is going to be extremely disruptive to all existing users (if you use -Werror, it will require updating every call site). Have we considered encouraging the usage of the new method while not deprecating the old methods? We could consider deprecation down the line.

[jira] [Resolved] (KAFKA-12589) There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0) , this is not expected;

[ https://issues.apache.org/jira/browse/KAFKA-12589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guido Raimondi resolved KAFKA-12589. Resolution: Not A Problem I discovered that the problem is due to my mistake. sorry >

Re: Re: [DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

Hi, Starting with the KIP as written: 1. I think the Builder.key() and Builder.value() methods in the KIP have the wrong parameter type: Should be K and V I think. 2. I'm not sure that having separate Builder.topic() and .partition() methods is better than forcing people to set the target via a

[jira] [Created] (KAFKA-12592) Remove deprecated LogConfig.Compact

Ismael Juma created KAFKA-12592: --- Summary: Remove deprecated LogConfig.Compact Key: KAFKA-12592 URL: https://issues.apache.org/jira/browse/KAFKA-12592 Project: Kafka Issue Type: Task

[jira] [Resolved] (KAFKA-12582) Remove deprecated `ConfigEntry` constructor

[ https://issues.apache.org/jira/browse/KAFKA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12582. - Resolution: Duplicate > Remove deprecated `ConfigEntry` constructor >

[jira] [Reopened] (KAFKA-12582) Remove deprecated `ConfigEntry` constructor

[ https://issues.apache.org/jira/browse/KAFKA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reopened KAFKA-12582: - > Remove deprecated `ConfigEntry` constructor > --- > >

[jira] [Created] (KAFKA-12591) Remove deprecated `quota.producer.default` and `quota.consumer.default` configurations

David Jacot created KAFKA-12591: --- Summary: Remove deprecated `quota.producer.default` and `quota.consumer.default` configurations Key: KAFKA-12591 URL: https://issues.apache.org/jira/browse/KAFKA-12591

[jira] [Created] (KAFKA-12590) Remove deprecated SimpleAclAuthorizer

Ismael Juma created KAFKA-12590: --- Summary: Remove deprecated SimpleAclAuthorizer Key: KAFKA-12590 URL: https://issues.apache.org/jira/browse/KAFKA-12590 Project: Kafka Issue Type: Task

[jira] [Resolved] (KAFKA-12582) Remove deprecated `ConfigEntry` constructor

[ https://issues.apache.org/jira/browse/KAFKA-12582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12582. - Fix Version/s: 3.0.0 Resolution: Fixed > Remove deprecated `ConfigEntry` constructor >

[jira] [Reopened] (KAFKA-12577) Remove deprecated `quota.producer.default` and `quota.consumer.default` configurations

[ https://issues.apache.org/jira/browse/KAFKA-12577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-12577: - > Remove deprecated `quota.producer.default` and `quota.consumer.default` > configurations >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #683

See Changes: [github] KAFKA-12577; Remove deprecated `ConfigEntry` constructor for 3.0 (#10436) -- [...truncated 7.38 MB...] AclAuthorizerTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #622

See Changes: [github] KAFKA-12577; Remove deprecated `ConfigEntry` constructor for 3.0 (#10436) -- [...truncated 3.67 MB...] ControllerChannelManagerTest >

[jira] [Resolved] (KAFKA-12533) Migrate KStream stateless operators to new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-12533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-12533. -- Resolution: Duplicate > Migrate KStream stateless operators

[jira] [Resolved] (KAFKA-12532) Migrate Stream operators to new Processor API

[ https://issues.apache.org/jira/browse/KAFKA-12532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jorge Esteban Quilcate Otoya resolved KAFKA-12532. -- Resolution: Duplicate > Migrate Stream operators to new

[jira] [Created] (KAFKA-12589) There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0) , this is not expected;

Guido Raimondi created KAFKA-12589: -- Summary: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0) , this is not expected; Key: KAFKA-12589 URL:

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #651

See Changes: [github] KAFKA-12577; Remove deprecated `ConfigEntry` constructor for 3.0 (#10436) -- [...truncated 3.70 MB...] PartitionLockTest >

[jira] [Resolved] (KAFKA-12577) Remove deprecated `quota.producer.default` and `quota.consumer.default` configurations

[ https://issues.apache.org/jira/browse/KAFKA-12577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12577. - Fix Version/s: 3.0.0 Reviewer: Ismael Juma Resolution: Fixed > Remove

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #682

See Changes: [github] KAFKA-12578: Remove deprecated security classes/methods for 3.0 (#10435) [github] KAFKA-12581: Remove deprecated `Admin.electPreferredLeaders` (#10440) [github] KAFKA-12561:

[jira] [Created] (KAFKA-12588) Remove deprecated --zookeeper in shell commands

Luke Chen created KAFKA-12588: - Summary: Remove deprecated --zookeeper in shell commands Key: KAFKA-12588 URL: https://issues.apache.org/jira/browse/KAFKA-12588 Project: Kafka Issue Type: Task

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #621

See Changes: [github] MINOR: Remove unnecessary suppress (#10434) [github] KAFKA-12578: Remove deprecated security classes/methods for 3.0 (#10435) [github] KAFKA-12581: Remove deprecated

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #650

See Changes: [github] KAFKA-12578: Remove deprecated security classes/methods for 3.0 (#10435) [github] KAFKA-12581: Remove deprecated `Admin.electPreferredLeaders` (#10440) [github] KAFKA-12561:

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #681

See Changes: [github] MINOR: Remove unnecessary suppress (#10434) -- [...truncated 3.69 MB...] UserQuotaTest > testThrottledProducerConsumer() STARTED

Jenkins build is back to normal : Kafka » kafka-trunk-jdk8 #620

See