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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
Apoorv Mittal created KAFKA-16492:
-
Summary: Flaky test:
testAlterSinkConnectorOffsetsDifferentKafkaClusterTargeted –
org.apache.kafka.connect.integration.OffsetsApiIntegrationTest
Key: KAFKA-16492
URL:
Apoorv Mittal created KAFKA-16491:
-
Summary: Flaky test:
randomClusterPerturbationsShouldConverge[rackAwareStrategy=balance_subtopology]
–
org.apache.kafka.streams.processor.internals.assignment.TaskAssignorConvergenceTest
Key:
Apoorv Mittal created KAFKA-16486:
-
Summary: Integrate metric measurability changes in metrics
collector
Key: KAFKA-16486
URL: https://issues.apache.org/jira/browse/KAFKA-16486
Project: Kafka
Apoorv Mittal created KAFKA-16485:
-
Summary: Fix broker metrics to follow kebab/hyphen case
Key: KAFKA-16485
URL: https://issues.apache.org/jira/browse/KAFKA-16485
Project: Kafka
Issue Type:
Apoorv Mittal created KAFKA-16280:
-
Summary: Expose method to determine Metric Measurability
Key: KAFKA-16280
URL: https://issues.apache.org/jira/browse/KAFKA-16280
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-15683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-15683.
---
Resolution: Not A Problem
Closing ticket as this is not required, it works as per the
Apoorv Mittal created KAFKA-16187:
-
Summary: Flaky test: testTopicPatternArg -
org.apache.kafka.tools.GetOffsetShellTest
Key: KAFKA-16187
URL: https://issues.apache.org/jira/browse/KAFKA-16187
Apoorv Mittal created KAFKA-16186:
-
Summary: Implement broker metrics for client telemetry usage
Key: KAFKA-16186
URL: https://issues.apache.org/jira/browse/KAFKA-16186
Project: Kafka
Issue
Apoorv Mittal created KAFKA-16177:
-
Summary: Flaky test: testBatchSizeZeroNoPartitionNoRecordKey –
kafka.api.PlaintextProducerSendTest
Key: KAFKA-16177
URL: https://issues.apache.org/jira/browse/KAFKA-16177
Apoorv Mittal created KAFKA-16176:
-
Summary: Flaky test:
testSendToPartitionWithFollowerShutdownShouldNotTimeout –
kafka.api.PlaintextProducerSendTest
Key: KAFKA-16176
URL:
Apoorv Mittal created KAFKA-16175:
-
Summary: Flaky test:
testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads –
kafka.api.SslAdminIntegrationTest
Key: KAFKA-16175
URL:
Apoorv Mittal created KAFKA-16174:
-
Summary: Flaky test: testDescribeQuorumStatusSuccessful –
org.apache.kafka.tools.MetadataQuorumCommandTest
Key: KAFKA-16174
URL:
Apoorv Mittal created KAFKA-16173:
-
Summary: Flaky test: testTimeoutMetrics –
org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest
Key: KAFKA-16173
URL:
Apoorv Mittal created KAFKA-16172:
-
Summary: Flaky test: testProducerConsumerOverrideLowerQuota –
kafka.api.UserQuotaTest
Key: KAFKA-16172
URL: https://issues.apache.org/jira/browse/KAFKA-16172
[
https://issues.apache.org/jira/browse/KAFKA-15807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-15807.
---
Resolution: Done
> Add support for compression/decompression of metrics
>
[
https://issues.apache.org/jira/browse/KAFKA-15863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-15863.
---
Resolution: Not A Problem
> Handle push telemetry throttling with quota manager
>
[
https://issues.apache.org/jira/browse/KAFKA-15952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-15952.
---
Resolution: Won't Do
> Create public doc for telemetry state transition
>
[
https://issues.apache.org/jira/browse/KAFKA-15958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-15958.
---
Resolution: Won't Do
> Add tests to validate telemetry requests with different version
>
[
https://issues.apache.org/jira/browse/KAFKA-15972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-15972.
---
Resolution: Done
> Add support to exclude labels in client telemetry
>
[
https://issues.apache.org/jira/browse/KAFKA-15877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Apoorv Mittal resolved KAFKA-15877.
---
Resolution: Done
> Support change of temporality in Java client
>
Apoorv Mittal created KAFKA-15972:
-
Summary: Add support to exclude labels in client telemetry
Key: KAFKA-15972
URL: https://issues.apache.org/jira/browse/KAFKA-15972
Project: Kafka
Issue
Apoorv Mittal created KAFKA-15965:
-
Summary: Test failure:
org.apache.kafka.common.requests.BrokerRegistrationRequestTest
Key: KAFKA-15965
URL: https://issues.apache.org/jira/browse/KAFKA-15965
Apoorv Mittal created KAFKA-15963:
-
Summary: Flaky test: testBrokerHeartbeatDuringMigration [3]
3.6-IV0 – org.apache.kafka.controller.QuorumControllerTest
Key: KAFKA-15963
URL:
Apoorv Mittal created KAFKA-15964:
-
Summary: Flaky test:
testHighAvailabilityTaskAssignorLargeNumConsumers –
org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest
Key: KAFKA-15964
URL:
Apoorv Mittal created KAFKA-15962:
-
Summary: Flaky test:
testAlterPartitionVersion2KeepWorkingWhenControllerDowngradeToPre28IBP() –
kafka.controller.ControllerIntegrationTest
Key: KAFKA-15962
URL:
Apoorv Mittal created KAFKA-15961:
-
Summary: Flaky test:
testTopicIdPersistsThroughControllerRestart() –
kafka.controller.ControllerIntegrationTest
Key: KAFKA-15961
URL:
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
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
[
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
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
Apoorv Mittal created KAFKA-15941:
-
Summary: Flaky test: shouldRestoreNullRecord() –
org.apache.kafka.streams.integration.RestoreIntegrationTest
Key: KAFKA-15941
URL:
Apoorv Mittal created KAFKA-15940:
-
Summary: Flaky test: testLogCleanerConfig(String).quorum=kraft –
kafka.server.DynamicBrokerReconfigurationTest
Key: KAFKA-15940
URL:
Apoorv Mittal created KAFKA-15939:
-
Summary: Flaky test: testInvalidAlterConfigs(String).quorum=kraft
– kafka.api.AdminClientWithPoliciesIntegrationTest
Key: KAFKA-15939
URL:
Apoorv Mittal created KAFKA-15938:
-
Summary: Flaky test:
testCreateRemoteTopicWithValidRetentionTime(String).quorum=kraft –
kafka.admin.RemoteTopicCrudTest
Key: KAFKA-15938
URL:
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
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
Apoorv Mittal created KAFKA-15935:
-
Summary: Flaky test: testRestartReplication() –
org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest
Key: KAFKA-15935
URL:
Apoorv Mittal created KAFKA-15934:
-
Summary: Flaky test: testMultiConsumerStickyAssignor(String,
String).quorum=kraft+kip848.groupProtocol=generic –
kafka.api.PlaintextConsumerTest
Key: KAFKA-15934
URL:
Apoorv Mittal created KAFKA-15933:
-
Summary: Flaky test: testRestartReplication() –
org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationTransactionsTest
Key: KAFKA-15933
URL:
[
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:
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
Apoorv Mittal created KAFKA-15900:
-
Summary: Flaky test: testOutdatedCoordinatorAssignment() –
org.apache.kafka.clients.consumer.internals.EagerConsumerCoordinatorTest
Key: KAFKA-15900
URL:
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
Apoorv Mittal created KAFKA-15897:
-
Summary: Flaky Test: testWrongIncarnationId() –
kafka.server.ControllerRegistrationManagerTest
Key: KAFKA-15897
URL: https://issues.apache.org/jira/browse/KAFKA-15897
Apoorv Mittal created KAFKA-15896:
-
Summary: Flaky test: shouldQuerySpecificStalePartitionStores() –
org.apache.kafka.streams.integration.StoreQueryIntegrationTest
Key: KAFKA-15896
URL:
Apoorv Mittal created KAFKA-15892:
-
Summary: Flaky test: testAlterSinkConnectorOffsets –
org.apache.kafka.connect.integration.OffsetsApiIntegrationTest
Key: KAFKA-15892
URL:
Apoorv Mittal created KAFKA-15891:
-
Summary: Flaky test:
testResetSinkConnectorOffsetsOverriddenConsumerGroupId –
org.apache.kafka.connect.integration.OffsetsApiIntegrationTest
Key: KAFKA-15891
URL:
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:
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
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
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:
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:
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
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
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:
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
Apoorv Mittal created KAFKA-15791:
-
Summary: Investigate new test case failure -
MirrorConnectorsWithCustomForwardingAdminIntegrationTest -
MirrorConnectorsIntegrationBaseTest
Key: KAFKA-15791
URL:
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
Apoorv Mittal created KAFKA-15790:
-
Summary: Investigate new test case failure -
testHighWaterMarkAfterPartitionReassignment
Key: KAFKA-15790
URL: https://issues.apache.org/jira/browse/KAFKA-15790
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:
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
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
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
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:
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
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
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
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
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
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
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
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
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:
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
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
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
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
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
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
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
98 matches
Mail list logo
