[jira] [Created] (KAFKA-16758) Extend Consumer#close with option to leave the group or not

A. Sophie Blee-Goldman created KAFKA-16758: -- Summary: Extend Consumer#close with option to leave the group or not Key: KAFKA-16758 URL: https://issues.apache.org/jira/browse/KAFKA-16758

Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing

+1 (binding) On 5/13/24 5:54 PM, Sophie Blee-Goldman wrote: Thanks for the KIP guys! +1 (binding) On Mon, May 13, 2024 at 6:02 AM Bill Bejeck wrote: Thanks for the KIP, this will be a great addition! +1(binding) -Bill On Fri, May 3, 2024 at 4:48 AM Bruno Cadonna wrote: Hi Damien,

Re: [KAFKA-16361] Rack aware sticky assignor minQuota violations

Please check the pr , the logic in AbstractStickyAssignor has many mistakes, though it's been a long time since pr submitted, I couldn't remember the whole detail now. Julien Opoix 于2024年5月14日周二 03:55写道： > Hi there, > > We're facing a critical issue

Re: [KAFKA-16361] Rack aware sticky assignor minQuota violations

Hey, Took a look at the ticket and left a comment. Seems like narrowing down which versions this affects is a good first step, after that I'm happy to help you understand the code and put together a fix if you're willing. I'd recommend starting out by going through the "constrainedAssign" method

Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing

Thanks for the KIP guys! +1 (binding) On Mon, May 13, 2024 at 6:02 AM Bill Bejeck wrote: > Thanks for the KIP, this will be a great addition! > > +1(binding) > > -Bill > > On Fri, May 3, 2024 at 4:48 AM Bruno Cadonna wrote: > > > Hi Damien, Sébastien, and Loïc, > > > > Thanks for the KIP! > >

[jira] [Created] (KAFKA-16757) Fix broker re-registration issues around MV 3.7-IV2

Colin McCabe created KAFKA-16757: Summary: Fix broker re-registration issues around MV 3.7-IV2 Key: KAFKA-16757 URL: https://issues.apache.org/jira/browse/KAFKA-16757 Project: Kafka Issue

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

Hi all, Thanks for all the valid points you listed. KIP updates and addressing concerns: 1) The KIP now suggests two Response types: `RetryableResponse` and `NonRetryableResponse` 2) `custom.exception.handler` is changed to `custom.exception.handler.class` 3) The KIP clarifies that `In

Re: DISCUSS KIP-984 Add pluggable compression interface to Kafka

Hi Assane, Thank you for the further information about your motivation and intended use-cases, that adds a lot of context. > Our motivation here is to accelerate compression with the use of hardware > accelerators. This is a very broad statement, so let me break it down into cases, and what I

[KAFKA-16361] Rack aware sticky assignor minQuota violations

Hi there, We're facing a critical issue with Java Kafka client version 3.5+ and sticky assignors (details here: https://issues.apache.org/jira/browse/KAFKA-16361). Could we request prioritization for this issue? We're willing to assist, if necessary, though guidance would be appreciated given

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #2898

See

Re: [DISCUSS] KIP-1028: Docker Official Image for Apache Kafka

Hey Chris, Once we provide the definitions to docker, they should take care of everything from there. They mentioned here that the image will be rebuilt when the base image is updated. Hence active

[jira] [Resolved] (KAFKA-15578) Run System Tests for Old protocol in the New Coordinator

[ https://issues.apache.org/jira/browse/KAFKA-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-15578. - Resolution: Fixed > Run System Tests for Old protocol in the New Coordinator >

Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception

+1 (non-binding) Thanks Fred! > On May 13, 2024, at 5:46 AM, Bill Bejeck wrote: > > Thanks for the KIP! > > +1 (binding) > > -Bill > > > On Tue, May 7, 2024 at 6:16 PM Sophie Blee-Goldman > wrote: > >> +1 (binding) >> >> thanks for the KIP! >> >> On Fri, May 3, 2024 at 9:13 AM Matthias

[jira] [Resolved] (KAFKA-16117) Add Integration test for checking if the correct assignor is chosen

[ https://issues.apache.org/jira/browse/KAFKA-16117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16117. - Fix Version/s: 3.8.0 Resolution: Fixed > Add Integration test for checking if the

[jira] [Resolved] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8

[ https://issues.apache.org/jira/browse/KAFKA-16735?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-16735. - Resolution: Fixed > Deprecate offsets.commit.required.acks in 3.8 >

RE: DISCUSS KIP-984 Add pluggable compression interface to Kafka

Hi Greg, Thank you for your thoughtful response. Resending this email to continue engagement on the KIP discussion. Our motivation here is to accelerate compression with the use of hardware accelerators. If the community prefers, we would be happy to contribute code to support compression

Re: [DISCUSS] KIP-891: Running multiple versions of Connector plugins

Hi Greg, That is much appreciated. No complaints on the additional scope, I will make some time out to work on this once we have approval. Thanks Snehashis On Fri, May 10, 2024 at 9:28 PM Greg Harris wrote: > Hey Snehashis, > > I'm glad to hear you're still interested in this KIP! > I'm happy

[jira] [Created] (KAFKA-16755) Implement lock timeout functionality in SharePartition

Apoorv Mittal created KAFKA-16755: - Summary: Implement lock timeout functionality in SharePartition Key: KAFKA-16755 URL: https://issues.apache.org/jira/browse/KAFKA-16755 Project: Kafka

[jira] [Created] (KAFKA-16756) Implement max delivery count functionality in SharePartition

Apoorv Mittal created KAFKA-16756: - Summary: Implement max delivery count functionality in SharePartition Key: KAFKA-16756 URL: https://issues.apache.org/jira/browse/KAFKA-16756 Project: Kafka

[jira] [Created] (KAFKA-16754) Implement release acquired records functionality in SharePartition

Apoorv Mittal created KAFKA-16754: - Summary: Implement release acquired records functionality in SharePartition Key: KAFKA-16754 URL: https://issues.apache.org/jira/browse/KAFKA-16754 Project: Kafka

[jira] [Created] (KAFKA-16753) Implement acknowledge functionality in SharePartition

Apoorv Mittal created KAFKA-16753: - Summary: Implement acknowledge functionality in SharePartition Key: KAFKA-16753 URL: https://issues.apache.org/jira/browse/KAFKA-16753 Project: Kafka

[jira] [Created] (KAFKA-16752) Implement acquire functionality in SharePartition

Apoorv Mittal created KAFKA-16752: - Summary: Implement acquire functionality in SharePartition Key: KAFKA-16752 URL: https://issues.apache.org/jira/browse/KAFKA-16752 Project: Kafka Issue

[jira] [Created] (KAFKA-16749) Implement share fetch messages

Apoorv Mittal created KAFKA-16749: - Summary: Implement share fetch messages Key: KAFKA-16749 URL: https://issues.apache.org/jira/browse/KAFKA-16749 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-16751) Implement release acquired records in SharePartitionManager

Apoorv Mittal created KAFKA-16751: - Summary: Implement release acquired records in SharePartitionManager Key: KAFKA-16751 URL: https://issues.apache.org/jira/browse/KAFKA-16751 Project: Kafka

[jira] [Created] (KAFKA-16750) Implement acknowledge API in SharePartitionManager

Apoorv Mittal created KAFKA-16750: - Summary: Implement acknowledge API in SharePartitionManager Key: KAFKA-16750 URL: https://issues.apache.org/jira/browse/KAFKA-16750 Project: Kafka Issue

[jira] [Created] (KAFKA-16747) Implement share sessions and context

Apoorv Mittal created KAFKA-16747: - Summary: Implement share sessions and context Key: KAFKA-16747 URL: https://issues.apache.org/jira/browse/KAFKA-16747 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-16748) Implement share response handling in SharePartitionManager

Apoorv Mittal created KAFKA-16748: - Summary: Implement share response handling in SharePartitionManager Key: KAFKA-16748 URL: https://issues.apache.org/jira/browse/KAFKA-16748 Project: Kafka

[jira] [Created] (KAFKA-16746) Add support for share acknowledgement request in KafkaApis

Apoorv Mittal created KAFKA-16746: - Summary: Add support for share acknowledgement request in KafkaApis Key: KAFKA-16746 URL: https://issues.apache.org/jira/browse/KAFKA-16746 Project: Kafka

[jira] [Created] (KAFKA-16745) Add support for share fetch request in KafkaApis

Apoorv Mittal created KAFKA-16745: - Summary: Add support for share fetch request in KafkaApis Key: KAFKA-16745 URL: https://issues.apache.org/jira/browse/KAFKA-16745 Project: Kafka Issue

[jira] [Created] (KAFKA-16744) Add support for share group describe in KafkaApis

Apoorv Mittal created KAFKA-16744: - Summary: Add support for share group describe in KafkaApis Key: KAFKA-16744 URL: https://issues.apache.org/jira/browse/KAFKA-16744 Project: Kafka Issue

[jira] [Created] (KAFKA-16743) Add support for share group heartbeat in KafkaApis

Apoorv Mittal created KAFKA-16743: - Summary: Add support for share group heartbeat in KafkaApis Key: KAFKA-16743 URL: https://issues.apache.org/jira/browse/KAFKA-16743 Project: Kafka Issue

[jira] [Created] (KAFKA-16741) Add SharGroupHeartbeat API support in GroupCoordinator

Apoorv Mittal created KAFKA-16741: - Summary: Add SharGroupHeartbeat API support in GroupCoordinator Key: KAFKA-16741 URL: https://issues.apache.org/jira/browse/KAFKA-16741 Project: Kafka

[jira] [Created] (KAFKA-16742) Add ShareGroupDescribe API support in GroupCoordinator

Apoorv Mittal created KAFKA-16742: - Summary: Add ShareGroupDescribe API support in GroupCoordinator Key: KAFKA-16742 URL: https://issues.apache.org/jira/browse/KAFKA-16742 Project: Kafka

[jira] [Created] (KAFKA-16740) Define skeleton for SharePartitionManager and SharePartition

Apoorv Mittal created KAFKA-16740: - Summary: Define skeleton for SharePartitionManager and SharePartition Key: KAFKA-16740 URL: https://issues.apache.org/jira/browse/KAFKA-16740 Project: Kafka

[jira] [Created] (KAFKA-16739) Exclude protected variables from aggregated JavaDocs

Greg Harris created KAFKA-16739: --- Summary: Exclude protected variables from aggregated JavaDocs Key: KAFKA-16739 URL: https://issues.apache.org/jira/browse/KAFKA-16739 Project: Kafka Issue

Re: [DISCUSS] KIP-1028: Docker Official Image for Apache Kafka

Thanks both for your responses! Friendly reminder: again, better to provide a quote instead of just a link :) I've seen a bit about image rebuilding to handle CVEs but I'm a little unclear on how this would work in practice, and I couldn't find any concrete details in any of the links. Does

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

Oh I see. The type isn't the error type but a newly defined type for the response. Makes sense and works for me. Justine On Mon, May 13, 2024 at 9:13 AM Chris Egerton wrote: > If we have dedicated methods for each kind of exception > (handleRecordTooLarge, handleUnknownTopicOrPartition, etc.),

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

If we have dedicated methods for each kind of exception (handleRecordTooLarge, handleUnknownTopicOrPartition, etc.), doesn't that provide sufficient constraint? I'm not suggesting we eliminate these methods, just that we change their return types to something more flexible. On Mon, May 13, 2024,

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

I'm not sure I agree with the Retriable and NonRetriableResponse comment. This doesn't limit the blast radius or enforce certain errors are used. I think we might disagree on how controlled these interfaces can be... Justine On Mon, May 13, 2024 at 8:40 AM Chris Egerton wrote: > Hi Alieh, > >

Re: [DISCUSS] KIP-950: Tiered Storage Disablement

Heya! re Kamal - Okay, I believe I understand what you mean and I agree. I have made the following change ``` During tiered storage disablement, when RemoteLogManager#stopPartition() is called: - Tasks scheduled for the topic-partitions in the RemoteStorageCopierThreadPool will be

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

Hi Alieh, Thanks for the updates! I just have a few more thoughts: - I don't think a boolean property is sufficient to dictate retries for unknown topic partitions, though. These errors can occur if a topic has just been created, which can occur if, for example, automatic topic creation is

[jira] [Created] (KAFKA-16738) Returns BaseRecords instead of MemoryRecords

Zhenyu Luo created KAFKA-16738: -- Summary: Returns BaseRecords instead of MemoryRecords Key: KAFKA-16738 URL: https://issues.apache.org/jira/browse/KAFKA-16738 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

Hi Alieh, Just a few more comments on the KIP. It is looking much less risky now the scope is tighter. [AJS1] It would be nice to have default implementations of the handle methods so an implementor would not need to implement both themselves. [AJS2] Producer configurations which are class names

[KAFKA-16361] Rack aware sticky assignor minQuota violations

Hi there, We're facing a critical issue with Java Kafka client version 3.5+ and sticky assignors (details here: https://issues.apache.org/jira/browse/KAFKA-16361). Could we request prioritization for this issue? We're willing to assist, if necessary, though guidance would be appreciated given

Re: KIP-1040: Improve handling of nullable values in InsertField/ExtractField transformations

Hi all, Any other suggestions/objections/dubs? On Fri, May 10, 2024 at 5:10 PM Chris Egerton wrote: >  Done > > On Fri, May 10, 2024, 10:55 Mario Fiore Vitale wrote: > > > Thanks a lot! I have just a minor comment, should we also update the > title > > to be more generic since now it's also

Re: [DISCUSS] KIP-1038: Add Custom Error Handler to Producer

Hi all, Thanks for the very interesting discussion during my PTO. KIP updates and addressing concerns: 1) Two handle() methods are defined in ProducerExceptionHandler for the two exceptions with different input parameters so that we have handle(RecordTooLargeException e, ProducerRecord

[jira] [Created] (KAFKA-16737) Clean up KafkaConsumerTest TODOs enabling tests for new consumer

Lianet Magrans created KAFKA-16737: -- Summary: Clean up KafkaConsumerTest TODOs enabling tests for new consumer Key: KAFKA-16737 URL: https://issues.apache.org/jira/browse/KAFKA-16737 Project: Kafka

Re: [VOTE] KIP-1033: Add Kafka Streams exception handler for exceptions occurring during processing

Thanks for the KIP, this will be a great addition! +1(binding) -Bill On Fri, May 3, 2024 at 4:48 AM Bruno Cadonna wrote: > Hi Damien, Sébastien, and Loïc, > > Thanks for the KIP! > > +1 (binding) > > Best, > Bruno > > > On 4/26/24 4:00 PM, Damien Gasparina wrote: > > Hi all, > > > > We would

Re: [VOTE] KIP-1036: Extend RecordDeserializationException exception

Thanks for the KIP! +1 (binding) -Bill On Tue, May 7, 2024 at 6:16 PM Sophie Blee-Goldman wrote: > +1 (binding) > > thanks for the KIP! > > On Fri, May 3, 2024 at 9:13 AM Matthias J. Sax wrote: > > > +1 (binding) > > > > On 5/3/24 8:52 AM, Federico Valeri wrote: > > > Hi Fred, this is a

[jira] [Created] (KAFKA-16736) Remove offsets.commit.required.acks in 4.0

David Jacot created KAFKA-16736: --- Summary: Remove offsets.commit.required.acks in 4.0 Key: KAFKA-16736 URL: https://issues.apache.org/jira/browse/KAFKA-16736 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16735) Deprecate offsets.commit.required.acks in 3.8

David Jacot created KAFKA-16735: --- Summary: Deprecate offsets.commit.required.acks in 3.8 Key: KAFKA-16735 URL: https://issues.apache.org/jira/browse/KAFKA-16735 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16734) Add support for formatting records written to share-group state topic

Andrew Schofield created KAFKA-16734: Summary: Add support for formatting records written to share-group state topic Key: KAFKA-16734 URL: https://issues.apache.org/jira/browse/KAFKA-16734

[jira] [Created] (KAFKA-16730) Initial code for share-group consumer

Andrew Schofield created KAFKA-16730: Summary: Initial code for share-group consumer Key: KAFKA-16730 URL: https://issues.apache.org/jira/browse/KAFKA-16730 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16733) Add support for formatting new records written to offsets topic

Andrew Schofield created KAFKA-16733: Summary: Add support for formatting new records written to offsets topic Key: KAFKA-16733 URL: https://issues.apache.org/jira/browse/KAFKA-16733 Project:

[jira] [Created] (KAFKA-16732) Support for share-coordinator-metrics in the broker

Andrew Schofield created KAFKA-16732: Summary: Support for share-coordinator-metrics in the broker Key: KAFKA-16732 URL: https://issues.apache.org/jira/browse/KAFKA-16732 Project: Kafka

[jira] [Created] (KAFKA-16731) Support for share-group-metrics in the broker

Andrew Schofield created KAFKA-16731: Summary: Support for share-group-metrics in the broker Key: KAFKA-16731 URL: https://issues.apache.org/jira/browse/KAFKA-16731 Project: Kafka Issue

[jira] [Created] (KAFKA-16728) Add dynamic group configuration for heartbeat interval and session timeout

Andrew Schofield created KAFKA-16728: Summary: Add dynamic group configuration for heartbeat interval and session timeout Key: KAFKA-16728 URL: https://issues.apache.org/jira/browse/KAFKA-16728

[jira] [Created] (KAFKA-16729) Support for read-committed isolation level

Andrew Schofield created KAFKA-16729: Summary: Support for read-committed isolation level Key: KAFKA-16729 URL: https://issues.apache.org/jira/browse/KAFKA-16729 Project: Kafka Issue

Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)

+1 (binding) from me too. The KIP passes with binding votes from Justine, Manikumar and me; and non-binding votes from Andrew and Federico. Thanks, David On Mon, May 13, 2024 at 1:52 PM Manikumar wrote: > +1 (binding). > > Thanks for the KIP. > > Manikumar > > On Wed, May 8, 2024 at 9:55 PM

[jira] [Created] (KAFKA-16726) Add dynamic group configuration for offset reset

Andrew Schofield created KAFKA-16726: Summary: Add dynamic group configuration for offset reset Key: KAFKA-16726 URL: https://issues.apache.org/jira/browse/KAFKA-16726 Project: Kafka

[jira] [Created] (KAFKA-16725) Add broker configurations

Andrew Schofield created KAFKA-16725: Summary: Add broker configurations Key: KAFKA-16725 URL: https://issues.apache.org/jira/browse/KAFKA-16725 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-16727) Add dynamic group configuration for record lock duration

Andrew Schofield created KAFKA-16727: Summary: Add dynamic group configuration for record lock duration Key: KAFKA-16727 URL: https://issues.apache.org/jira/browse/KAFKA-16727 Project: Kafka

[jira] [Created] (KAFKA-16724) Add new options for kafka-producer-perf-test.sh

Andrew Schofield created KAFKA-16724: Summary: Add new options for kafka-producer-perf-test.sh Key: KAFKA-16724 URL: https://issues.apache.org/jira/browse/KAFKA-16724 Project: Kafka

[jira] [Created] (KAFKA-16722) Add ConsumerGroupPartitionAssignor and ShareGroupPartitionAssignor

Andrew Schofield created KAFKA-16722: Summary: Add ConsumerGroupPartitionAssignor and ShareGroupPartitionAssignor Key: KAFKA-16722 URL: https://issues.apache.org/jira/browse/KAFKA-16722 Project:

[jira] [Created] (KAFKA-16723) Add kafka-console-share-consumer.sh

Andrew Schofield created KAFKA-16723: Summary: Add kafka-console-share-consumer.sh Key: KAFKA-16723 URL: https://issues.apache.org/jira/browse/KAFKA-16723 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16721) Add exceptions for the new error codes

Andrew Schofield created KAFKA-16721: Summary: Add exceptions for the new error codes Key: KAFKA-16721 URL: https://issues.apache.org/jira/browse/KAFKA-16721 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16718) Add AdminClient.deleteShareGroupOffsets

Andrew Schofield created KAFKA-16718: Summary: Add AdminClient.deleteShareGroupOffsets Key: KAFKA-16718 URL: https://issues.apache.org/jira/browse/KAFKA-16718 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16719) Add AdminClient.deleteShareGroups

Andrew Schofield created KAFKA-16719: Summary: Add AdminClient.deleteShareGroups Key: KAFKA-16719 URL: https://issues.apache.org/jira/browse/KAFKA-16719 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16717) Add AdminClient.alterShareGroupOffsets

Andrew Schofield created KAFKA-16717: Summary: Add AdminClient.alterShareGroupOffsets Key: KAFKA-16717 URL: https://issues.apache.org/jira/browse/KAFKA-16717 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16720) Add AdminClient.listShareGroupOffsets

Andrew Schofield created KAFKA-16720: Summary: Add AdminClient.listShareGroupOffsets Key: KAFKA-16720 URL: https://issues.apache.org/jira/browse/KAFKA-16720 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16716) Add AdminClient.describeShareGroups and AdminClient.listShareGroups

Andrew Schofield created KAFKA-16716: Summary: Add AdminClient.describeShareGroups and AdminClient.listShareGroups Key: KAFKA-16716 URL: https://issues.apache.org/jira/browse/KAFKA-16716 Project:

[jira] [Created] (KAFKA-16715) Create KafkaShareConsumer interface

Andrew Schofield created KAFKA-16715: Summary: Create KafkaShareConsumer interface Key: KAFKA-16715 URL: https://issues.apache.org/jira/browse/KAFKA-16715 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-16714) kafka-share-groups.sh supporting list and describe

Andrew Schofield created KAFKA-16714: Summary: kafka-share-groups.sh supporting list and describe Key: KAFKA-16714 URL: https://issues.apache.org/jira/browse/KAFKA-16714 Project: Kafka

[jira] [Created] (KAFKA-16713) Add new RPC definitions

Andrew Schofield created KAFKA-16713: Summary: Add new RPC definitions Key: KAFKA-16713 URL: https://issues.apache.org/jira/browse/KAFKA-16713 Project: Kafka Issue Type: Sub-task

Re: [VOTE] KIP-1041: Drop `offsets.commit.required.acks` config in 4.0 (deprecate in 3.8)

+1 (binding). Thanks for the KIP. Manikumar On Wed, May 8, 2024 at 9:55 PM Justine Olshan wrote: > > +1 (binding) > > Thanks, > Justine > > On Wed, May 8, 2024 at 8:36 AM Federico Valeri wrote: > > > +1 non binding > > > > Thanks > > > > On Wed, May 8, 2024 at 5:27 PM Andrew Schofield > >

[jira] [Created] (KAFKA-16712) Race while setting RemoteLogMetadataTopicPartitioner in TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest

Gaurav Narula created KAFKA-16712: - Summary: Race while setting RemoteLogMetadataTopicPartitioner in TopicBasedRemoteLogMetadataManagerMultipleSubscriptionsTest Key: KAFKA-16712 URL:

[jira] [Created] (KAFKA-16711) highestOffsetInRemoteStorage is not updated after logDir altering within broker

Luke Chen created KAFKA-16711: - Summary: highestOffsetInRemoteStorage is not updated after logDir altering within broker Key: KAFKA-16711 URL: https://issues.apache.org/jira/browse/KAFKA-16711 Project:

[jira] [Resolved] (KAFKA-16587) Store subscription model for consumer group in group state

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

Re: [DISCUSS] KIP-1028: Docker Official Image for Apache Kafka

Hi Chris, Sharing the requested links explaining why Docker Official images are considered more secure - https://www.docker.com/blog/enhancing-security-and-transparency-with-docker-official-images/ and https://github.com/docker-library/faq#why-does-my-security-scanner-show-that-an-image-has-cves

Re: [DISCUSS] KIP-1033: Add Kafka Streams exception handler for exceptions occuring during processing

Thanks for the feedback, I think we should keep two separate callbacks for serialization and error handlers. It makes sense for type safety (ProducerRecord vs POJO) and also for backward compatibility. On top of that, all metadata provided in the #handle method would need to be held in memory

[jira] [Created] (KAFKA-16710) Continuously `makeFollower` may cause the replica fetcher thread to encounter an offset mismatch exception when `processPartitionData`

hudeqi created KAFKA-16710: -- Summary: Continuously `makeFollower` may cause the replica fetcher thread to encounter an offset mismatch exception when `processPartitionData` Key: KAFKA-16710 URL:

[jira] [Resolved] (KAFKA-16663) CoordinatorRuntime write timer tasks should be cancelled once HWM advances

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

[jira] [Resolved] (KAFKA-16677) Replace ClusterType#ALL and ClusterType#DEFAULT by Array

[ https://issues.apache.org/jira/browse/KAFKA-16677?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-16677. Fix Version/s: 3.8.0 Resolution: Fixed > Replace ClusterType#ALL and