[jira] [Created] (KAFKA-15601) Client metrics and observability

Apoorv Mittal created KAFKA-15601: - Summary: Client metrics and observability Key: KAFKA-15601 URL: https://issues.apache.org/jira/browse/KAFKA-15601 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-15604) Add Telemetry RPCs Definitions

Apoorv Mittal created KAFKA-15604: - Summary: Add Telemetry RPCs Definitions Key: KAFKA-15604 URL: https://issues.apache.org/jira/browse/KAFKA-15604 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15613) Add Client API in interfaces and client configurations.

Apoorv Mittal created KAFKA-15613: - Summary: Add Client API in interfaces and client configurations. Key: KAFKA-15613 URL: https://issues.apache.org/jira/browse/KAFKA-15613 Project: Kafka Iss

[jira] [Created] (KAFKA-15614) Define interfaces/classes for capturing telemetry metrics

Apoorv Mittal created KAFKA-15614: - Summary: Define interfaces/classes for capturing telemetry metrics Key: KAFKA-15614 URL: https://issues.apache.org/jira/browse/KAFKA-15614 Project: Kafka

[jira] [Created] (KAFKA-15616) Define client telemetry states and their transitions

Apoorv Mittal created KAFKA-15616: - Summary: Define client telemetry states and their transitions Key: KAFKA-15616 URL: https://issues.apache.org/jira/browse/KAFKA-15616 Project: Kafka Issue

[jira] [Created] (KAFKA-15618) Implement MetricsCollector which collects metrics in OTLP format

Apoorv Mittal created KAFKA-15618: - Summary: Implement MetricsCollector which collects metrics in OTLP format Key: KAFKA-15618 URL: https://issues.apache.org/jira/browse/KAFKA-15618 Project: Kafka

[jira] [Created] (KAFKA-15662) Implement support for clientInstanceIds in Kafka Stream

Apoorv Mittal created KAFKA-15662: - Summary: Implement support for clientInstanceIds in Kafka Stream Key: KAFKA-15662 URL: https://issues.apache.org/jira/browse/KAFKA-15662 Project: Kafka Iss

[jira] [Created] (KAFKA-15663) Implement ClientTelemetryReporter which manages telemetry lifecyclye

Apoorv Mittal created KAFKA-15663: - Summary: Implement ClientTelemetryReporter which manages telemetry lifecyclye Key: KAFKA-15663 URL: https://issues.apache.org/jira/browse/KAFKA-15663 Project: Kafka

[jira] [Created] (KAFKA-15668) Add Opentelemetry Proto library with shadowed classes

Apoorv Mittal created KAFKA-15668: - Summary: Add Opentelemetry Proto library with shadowed classes Key: KAFKA-15668 URL: https://issues.apache.org/jira/browse/KAFKA-15668 Project: Kafka Issue

[jira] [Created] (KAFKA-15669) Implement telemetry naming strategy

Apoorv Mittal created KAFKA-15669: - Summary: Implement telemetry naming strategy Key: KAFKA-15669 URL: https://issues.apache.org/jira/browse/KAFKA-15669 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15673) Define new client_metrics resource type configuration to store metric config.

Apoorv Mittal created KAFKA-15673: - Summary: Define new client_metrics resource type configuration to store metric config. Key: KAFKA-15673 URL: https://issues.apache.org/jira/browse/KAFKA-15673 Proj

[jira] [Created] (KAFKA-15677) Add support for re2/j regex parsing for patterns

Apoorv Mittal created KAFKA-15677: - Summary: Add support for re2/j regex parsing for patterns Key: KAFKA-15677 URL: https://issues.apache.org/jira/browse/KAFKA-15677 Project: Kafka Issue Type

[jira] [Created] (KAFKA-15681) Add support of client-metrics in kafka-configs.sh

Apoorv Mittal created KAFKA-15681: - Summary: Add support of client-metrics in kafka-configs.sh Key: KAFKA-15681 URL: https://issues.apache.org/jira/browse/KAFKA-15681 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-15683) Delete subscription from metadata when all configs are deleted

Apoorv Mittal created KAFKA-15683: - Summary: Delete subscription from metadata when all configs are deleted Key: KAFKA-15683 URL: https://issues.apache.org/jira/browse/KAFKA-15683 Project: Kafka

[jira] [Created] (KAFKA-15684) Add support to describe all subscriptions through utility

Apoorv Mittal created KAFKA-15684: - Summary: Add support to describe all subscriptions through utility Key: KAFKA-15684 URL: https://issues.apache.org/jira/browse/KAFKA-15684 Project: Kafka I

[jira] [Created] (KAFKA-15778) Implement ClientMetricsManager to process request

Apoorv Mittal created KAFKA-15778: - Summary: Implement ClientMetricsManager to process request Key: KAFKA-15778 URL: https://issues.apache.org/jira/browse/KAFKA-15778 Project: Kafka Issue Typ

[jira] [Created] (KAFKA-15779) Define broker configurations and exceptions

Apoorv Mittal created KAFKA-15779: - Summary: Define broker configurations and exceptions Key: KAFKA-15779 URL: https://issues.apache.org/jira/browse/KAFKA-15779 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-15785) Investigate new test case failures

Apoorv Mittal created KAFKA-15785: - Summary: Investigate new test case failures Key: KAFKA-15785 URL: https://issues.apache.org/jira/browse/KAFKA-15785 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-15787) Investigate new test case failure - testReplicateSourceDefault

Apoorv Mittal created KAFKA-15787: - Summary: Investigate new test case failure - testReplicateSourceDefault Key: KAFKA-15787 URL: https://issues.apache.org/jira/browse/KAFKA-15787 Project: Kafka

[jira] [Created] (KAFKA-15786) Investigate new test case failure - testBumpTransactionalEpoch

Apoorv Mittal created KAFKA-15786: - Summary: Investigate new test case failure - testBumpTransactionalEpoch Key: KAFKA-15786 URL: https://issues.apache.org/jira/browse/KAFKA-15786 Project: Kafka

[jira] [Created] (KAFKA-15789) Investigate new test case failure - testTimeouts - QuorumControllerTest

Apoorv Mittal created KAFKA-15789: - Summary: Investigate new test case failure - testTimeouts - QuorumControllerTest Key: KAFKA-15789 URL: https://issues.apache.org/jira/browse/KAFKA-15789 Project: Ka

[jira] [Created] (KAFKA-15790) Investigate new test case failure - testHighWaterMarkAfterPartitionReassignment

Apoorv Mittal created KAFKA-15790: - Summary: Investigate new test case failure - testHighWaterMarkAfterPartitionReassignment Key: KAFKA-15790 URL: https://issues.apache.org/jira/browse/KAFKA-15790 Pro

[jira] [Created] (KAFKA-15788) Investigate new test case failure - testDeleteCmdNonExistingGroup

Apoorv Mittal created KAFKA-15788: - Summary: Investigate new test case failure - testDeleteCmdNonExistingGroup Key: KAFKA-15788 URL: https://issues.apache.org/jira/browse/KAFKA-15788 Project: Kafka

[jira] [Created] (KAFKA-15791) Investigate new test case failure - MirrorConnectorsWithCustomForwardingAdminIntegrationTest - MirrorConnectorsIntegrationBaseTest

Apoorv Mittal created KAFKA-15791: - Summary: Investigate new test case failure - MirrorConnectorsWithCustomForwardingAdminIntegrationTest - MirrorConnectorsIntegrationBaseTest Key: KAFKA-15791 URL: https://issues

[jira] [Created] (KAFKA-15794) Implement request and response handling for telemetry APIs

Apoorv Mittal created KAFKA-15794: - Summary: Implement request and response handling for telemetry APIs Key: KAFKA-15794 URL: https://issues.apache.org/jira/browse/KAFKA-15794 Project: Kafka

[jira] [Created] (KAFKA-15807) Add support for compress/decompress metrics

Apoorv Mittal created KAFKA-15807: - Summary: Add support for compress/decompress metrics Key: KAFKA-15807 URL: https://issues.apache.org/jira/browse/KAFKA-15807 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-15811) implement capturing client port information from Socket Server

Apoorv Mittal created KAFKA-15811: - Summary: implement capturing client port information from Socket Server Key: KAFKA-15811 URL: https://issues.apache.org/jira/browse/KAFKA-15811 Project: Kafka

[jira] [Created] (KAFKA-15812) Add support to send only sparse metrics, only non-zero values

Apoorv Mittal created KAFKA-15812: - Summary: Add support to send only sparse metrics, only non-zero values Key: KAFKA-15812 URL: https://issues.apache.org/jira/browse/KAFKA-15812 Project: Kafka

[jira] [Created] (KAFKA-15813) Improve implementation of client instnce cache

Apoorv Mittal created KAFKA-15813: - Summary: Improve implementation of client instnce cache Key: KAFKA-15813 URL: https://issues.apache.org/jira/browse/KAFKA-15813 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-15830) Add request/response handling in KafkaApis and update metrics plugin

Apoorv Mittal created KAFKA-15830: - Summary: Add request/response handling in KafkaApis and update metrics plugin Key: KAFKA-15830 URL: https://issues.apache.org/jira/browse/KAFKA-15830 Project: Kafka

[jira] [Created] (KAFKA-15850) Improve KafkaMetrics APIs to expose Value Provider information

Apoorv Mittal created KAFKA-15850: - Summary: Improve KafkaMetrics APIs to expose Value Provider information Key: KAFKA-15850 URL: https://issues.apache.org/jira/browse/KAFKA-15850 Project: Kafka

[jira] [Created] (KAFKA-15863) Handle push telemetry throttling with quota manager

Apoorv Mittal created KAFKA-15863: - Summary: Handle push telemetry throttling with quota manager Key: KAFKA-15863 URL: https://issues.apache.org/jira/browse/KAFKA-15863 Project: Kafka Issue T

[jira] [Created] (KAFKA-15877) Support change of temporality in Java client

Apoorv Mittal created KAFKA-15877: - Summary: Support change of temporality in Java client Key: KAFKA-15877 URL: https://issues.apache.org/jira/browse/KAFKA-15877 Project: Kafka Issue Type: S

[jira] [Created] (KAFKA-15891) Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest

Apoorv Mittal created KAFKA-15891: - Summary: Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest Key: KAFKA-15891 URL: https://issue

[jira] [Created] (KAFKA-15892) Flaky test: testAlterSinkConnectorOffsets – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest

Apoorv Mittal created KAFKA-15892: - Summary: Flaky test: testAlterSinkConnectorOffsets – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest Key: KAFKA-15892 URL: https://issues.apache.org/jira/browse/K

[jira] [Created] (KAFKA-15896) Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest

Apoorv Mittal created KAFKA-15896: - Summary: Flaky test: shouldQuerySpecificStalePartitionStores() – org.apache.kafka.streams.integration.StoreQueryIntegrationTest Key: KAFKA-15896 URL: https://issues.apache.org/j

[jira] [Created] (KAFKA-15897) Flaky Test: testWrongIncarnationId() – kafka.server.ControllerRegistrationManagerTest

Apoorv Mittal created KAFKA-15897: - Summary: Flaky Test: testWrongIncarnationId() – kafka.server.ControllerRegistrationManagerTest Key: KAFKA-15897 URL: https://issues.apache.org/jira/browse/KAFKA-15897

[jira] [Created] (KAFKA-15898) Flaky test: testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest

Apoorv Mittal created KAFKA-15898: - Summary: Flaky test: testFenceMultipleBrokers() – org.apache.kafka.controller.QuorumControllerTest Key: KAFKA-15898 URL: https://issues.apache.org/jira/browse/KAFKA-15898

[jira] [Created] (KAFKA-15900) Flaky test: testOutdatedCoordinatorAssignment() – org.apache.kafka.clients.consumer.internals.EagerConsumerCoordinatorTest

Apoorv Mittal created KAFKA-15900: - Summary: Flaky test: testOutdatedCoordinatorAssignment() – org.apache.kafka.clients.consumer.internals.EagerConsumerCoordinatorTest Key: KAFKA-15900 URL: https://issues.apache.o

[jira] [Created] (KAFKA-15901) Implement client changes to support telemetry APIs

Apoorv Mittal created KAFKA-15901: - Summary: Implement client changes to support telemetry APIs Key: KAFKA-15901 URL: https://issues.apache.org/jira/browse/KAFKA-15901 Project: Kafka Issue Ty

[jira] [Reopened] (KAFKA-14089) Flaky ExactlyOnceSourceIntegrationTest.testSeparateOffsetsTopic

[ https://issues.apache.org/jira/browse/KAFKA-14089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-14089: --- Assignee: (was: Chris Egerton) Failure occurred on PR build: https://ci-builds.apache

[jira] [Created] (KAFKA-15933) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest

Apoorv Mittal created KAFKA-15933: - Summary: Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest Key: KAFKA-15933 URL: https://issues.apac

[jira] [Created] (KAFKA-15934) Flaky test: testMultiConsumerStickyAssignor(String, String).quorum=kraft+kip848.groupProtocol=generic – kafka.api.PlaintextConsumerTest

Apoorv Mittal created KAFKA-15934: - Summary: Flaky test: testMultiConsumerStickyAssignor(String, String).quorum=kraft+kip848.groupProtocol=generic – kafka.api.PlaintextConsumerTest Key: KAFKA-15934 URL: https://i

[jira] [Created] (KAFKA-15935) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest

Apoorv Mittal created KAFKA-15935: - Summary: Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest Key: KAFKA-15935 URL: https://issues.apache.org/ji

[jira] [Created] (KAFKA-15936) Flaky tests for class: ConnectorTopicsIntegrationTest

Apoorv Mittal created KAFKA-15936: - Summary: Flaky tests for class: ConnectorTopicsIntegrationTest Key: KAFKA-15936 URL: https://issues.apache.org/jira/browse/KAFKA-15936 Project: Kafka Issue

[jira] [Created] (KAFKA-15937) Flaky test: testTopicDeletion(String).quorum=kraft – kafka.admin.RemoteTopicCrudTest

Apoorv Mittal created KAFKA-15937: - Summary: Flaky test: testTopicDeletion(String).quorum=kraft – kafka.admin.RemoteTopicCrudTest Key: KAFKA-15937 URL: https://issues.apache.org/jira/browse/KAFKA-15937

[jira] [Created] (KAFKA-15938) Flaky test: testCreateRemoteTopicWithValidRetentionTime(String).quorum=kraft – kafka.admin.RemoteTopicCrudTest

Apoorv Mittal created KAFKA-15938: - Summary: Flaky test: testCreateRemoteTopicWithValidRetentionTime(String).quorum=kraft – kafka.admin.RemoteTopicCrudTest Key: KAFKA-15938 URL: https://issues.apache.org/jira/br

[jira] [Created] (KAFKA-15939) Flaky test: testInvalidAlterConfigs(String).quorum=kraft – kafka.api.AdminClientWithPoliciesIntegrationTest

Apoorv Mittal created KAFKA-15939: - Summary: Flaky test: testInvalidAlterConfigs(String).quorum=kraft – kafka.api.AdminClientWithPoliciesIntegrationTest Key: KAFKA-15939 URL: https://issues.apache.org/jira/browse/

[jira] [Created] (KAFKA-15940) Flaky test: testLogCleanerConfig(String).quorum=kraft – kafka.server.DynamicBrokerReconfigurationTest

Apoorv Mittal created KAFKA-15940: - Summary: Flaky test: testLogCleanerConfig(String).quorum=kraft – kafka.server.DynamicBrokerReconfigurationTest Key: KAFKA-15940 URL: https://issues.apache.org/jira/browse/KAFKA-

[jira] [Created] (KAFKA-15941) Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest

Apoorv Mittal created KAFKA-15941: - Summary: Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest Key: KAFKA-15941 URL: https://issues.apache.org/jira/browse/KAFKA-15

[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-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 Issu

[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 Issu

[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 Ty

[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 Typ

[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 Type

[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-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-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-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 Ty

[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-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-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 Typ

[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 Issue

[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-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-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 Issu

[jira] [Created] (KAFKA-16822) Abstract consumer group in coordinator to share functionality with share group

Apoorv Mittal created KAFKA-16822: - Summary: Abstract consumer group in coordinator to share functionality with share group Key: KAFKA-16822 URL: https://issues.apache.org/jira/browse/KAFKA-16822 Proj

[jira] [Created] (KAFKA-16905) Thread block in describe topics API in Admin Client

Apoorv Mittal created KAFKA-16905: - Summary: Thread block in describe topics API in Admin Client Key: KAFKA-16905 URL: https://issues.apache.org/jira/browse/KAFKA-16905 Project: Kafka Issue T

[jira] [Created] (KAFKA-16914) Add Shage Group dynamic and broker configs

Apoorv Mittal created KAFKA-16914: - Summary: Add Shage Group dynamic and broker configs Key: KAFKA-16914 URL: https://issues.apache.org/jira/browse/KAFKA-16914 Project: Kafka Issue Type: Sub-

[jira] [Created] (KAFKA-16950) Define Persister and Share Coordinator RPCs

Apoorv Mittal created KAFKA-16950: - Summary: Define Persister and Share Coordinator RPCs Key: KAFKA-16950 URL: https://issues.apache.org/jira/browse/KAFKA-16950 Project: Kafka Issue Type: Sub

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

[ https://issues.apache.org/jira/browse/KAFKA-16752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16752. --- Resolution: Done > Implement acquire functionality in SharePartition > -

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

[ https://issues.apache.org/jira/browse/KAFKA-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16753. --- Resolution: Fixed > Implement acknowledge functionality in SharePartition >

[jira] [Created] (KAFKA-16999) Integrate persister read API in Partition leader initilization

Apoorv Mittal created KAFKA-16999: - Summary: Integrate persister read API in Partition leader initilization Key: KAFKA-16999 URL: https://issues.apache.org/jira/browse/KAFKA-16999 Project: Kafka

[jira] [Created] (KAFKA-17002) Integrate partition leader epoch in Share Partition

Apoorv Mittal created KAFKA-17002: - Summary: Integrate partition leader epoch in Share Partition Key: KAFKA-17002 URL: https://issues.apache.org/jira/browse/KAFKA-17002 Project: Kafka Issue T

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

[ https://issues.apache.org/jira/browse/KAFKA-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16748. --- Resolution: Fixed > Implement share response handling in SharePartitionManager > ---

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

[ https://issues.apache.org/jira/browse/KAFKA-16749?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16749. --- Resolution: Done > Implement share fetch messages > -- > >

[jira] [Resolved] (KAFKA-16999) Integrate persister read API in Partition leader initilization

[ https://issues.apache.org/jira/browse/KAFKA-16999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16999. --- Resolution: Done > Integrate persister read API in Partition leader initilization >

[jira] [Created] (KAFKA-17047) Refactor Consumer group and shared classes with Share to modern package

Apoorv Mittal created KAFKA-17047: - Summary: Refactor Consumer group and shared classes with Share to modern package Key: KAFKA-17047 URL: https://issues.apache.org/jira/browse/KAFKA-17047 Project: Ka

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

[ https://issues.apache.org/jira/browse/KAFKA-16756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16756. --- Resolution: Done Already merged as part of other code changes in Share Partition. > Impleme

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

[ https://issues.apache.org/jira/browse/KAFKA-16744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16744. --- Resolution: Fixed > Add support for share group describe in KafkaApis >

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

[ https://issues.apache.org/jira/browse/KAFKA-16743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16743. --- Resolution: Fixed > Add support for share group heartbeat in KafkaApis > ---

[jira] [Reopened] (KAFKA-15863) Handle push telemetry throttling with quota manager

[ https://issues.apache.org/jira/browse/KAFKA-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-15863: --- Reopening to introduce metric quota. > Handle push telemetry throttling with quota manager > --

[jira] [Created] (KAFKA-17230) Kafka consumer client doesn't report node request-latency metrics

Apoorv Mittal created KAFKA-17230: - Summary: Kafka consumer client doesn't report node request-latency metrics Key: KAFKA-17230 URL: https://issues.apache.org/jira/browse/KAFKA-17230 Project: Kafka

[jira] [Created] (KAFKA-17283) Add integration test for Share Group heartbeat

Apoorv Mittal created KAFKA-17283: - Summary: Add integration test for Share Group heartbeat Key: KAFKA-17283 URL: https://issues.apache.org/jira/browse/KAFKA-17283 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-17288) Remove tracking member partition epoch for share groups

Apoorv Mittal created KAFKA-17288: - Summary: Remove tracking member partition epoch for share groups Key: KAFKA-17288 URL: https://issues.apache.org/jira/browse/KAFKA-17288 Project: Kafka Iss

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

[ https://issues.apache.org/jira/browse/KAFKA-16742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-16742. --- Resolution: Fixed > Add ShareGroupDescribe API support in GroupCoordinator > ---

[jira] [Created] (KAFKA-17346) Refactor Share Sesssion Class to Server Module

Apoorv Mittal created KAFKA-17346: - Summary: Refactor Share Sesssion Class to Server Module Key: KAFKA-17346 URL: https://issues.apache.org/jira/browse/KAFKA-17346 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-17351) Validate compacted topics start offset handling in Share Partition

Apoorv Mittal created KAFKA-17351: - Summary: Validate compacted topics start offset handling in Share Partition Key: KAFKA-17351 URL: https://issues.apache.org/jira/browse/KAFKA-17351 Project: Kafka

[jira] [Created] (KAFKA-17362) Flaky test: kafka.api.AuthorizerIntegrationTest."testDeleteRecordsWithWildCardAuth(String).quorum=kraft"

Apoorv Mittal created KAFKA-17362: - Summary: Flaky test: kafka.api.AuthorizerIntegrationTest."testDeleteRecordsWithWildCardAuth(String).quorum=kraft" Key: KAFKA-17362 URL: https://issues.apache.org/jira/browse/KAF

[jira] [Created] (KAFKA-17363) Flaky test: kafka.api.PlaintextConsumerCommitTest.testAutoCommitOnRebalance(String, String).quorum=kraft+kip848.groupProtocol=consumer

Apoorv Mittal created KAFKA-17363: - Summary: Flaky test: kafka.api.PlaintextConsumerCommitTest.testAutoCommitOnRebalance(String, String).quorum=kraft+kip848.groupProtocol=consumer Key: KAFKA-17363 URL: https://is

[jira] [Created] (KAFKA-17364) Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldBeAbleQueryStandbyStateDuringRebalance()

Apoorv Mittal created KAFKA-17364: - Summary: Flaky test: org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldBeAbleQueryStandbyStateDuringRebalance() Key: KAFKA-17364 URL: https://issues.apach

[jira] [Created] (KAFKA-17365) Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testProduceAndConsumeWithReassignmentInProgress

Apoorv Mittal created KAFKA-17365: - Summary: Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testProduceAndConsumeWithReassignmentInProgress Key: KAFKA-17365 URL: https://issues.apache.or

[jira] [Created] (KAFKA-17366) Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testAlterReassignmentThrottle

Apoorv Mittal created KAFKA-17366: - Summary: Flaky test: org.apache.kafka.tools.reassign.ReassignPartitionsCommandTest.testAlterReassignmentThrottle Key: KAFKA-17366 URL: https://issues.apache.org/jira/browse/KAFK

[jira] [Created] (KAFKA-15952) Create public doc for telemetry state transition

Apoorv Mittal created KAFKA-15952: - Summary: Create public doc for telemetry state transition Key: KAFKA-15952 URL: https://issues.apache.org/jira/browse/KAFKA-15952 Project: Kafka Issue Type

[jira] [Reopened] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted`

[ https://issues.apache.org/jira/browse/KAFKA-9545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal reopened KAFKA-9545: -- Assignee: (was: Boyang Chen) > Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTop

[jira] [Created] (KAFKA-15958) Add tests to validate telemetry requests with different version

Apoorv Mittal created KAFKA-15958: - Summary: Add tests to validate telemetry requests with different version Key: KAFKA-15958 URL: https://issues.apache.org/jira/browse/KAFKA-15958 Project: Kafka

[jira] [Created] (KAFKA-15960) Flaky test: testQuotaOverrideDelete(String).quorum=kraft – kafka.api.ClientIdQuotaTest

Apoorv Mittal created KAFKA-15960: - Summary: Flaky test: testQuotaOverrideDelete(String).quorum=kraft – kafka.api.ClientIdQuotaTest Key: KAFKA-15960 URL: https://issues.apache.org/jira/browse/KAFKA-15960

[jira] [Created] (KAFKA-15961) Flaky test: testTopicIdPersistsThroughControllerRestart() – kafka.controller.ControllerIntegrationTest

Apoorv Mittal created KAFKA-15961: - Summary: Flaky test: testTopicIdPersistsThroughControllerRestart() – kafka.controller.ControllerIntegrationTest Key: KAFKA-15961 URL: https://issues.apache.org/jira/browse/KAF

[jira] [Created] (KAFKA-15962) Flaky test: testAlterPartitionVersion2KeepWorkingWhenControllerDowngradeToPre28IBP() – kafka.controller.ControllerIntegrationTest

Apoorv Mittal created KAFKA-15962: - Summary: Flaky test: testAlterPartitionVersion2KeepWorkingWhenControllerDowngradeToPre28IBP() – kafka.controller.ControllerIntegrationTest Key: KAFKA-15962 URL: https://issues.

  1   2   >