[jira] [Updated] (KAFKA-16741) Add ShareGroupHeartbeat API support in GroupCoordinator

[ https://issues.apache.org/jira/browse/KAFKA-16741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-16741: - Summary: Add ShareGroupHeartbeat API support in GroupCoordinator (was: Add

[jira] [Updated] (KAFKA-16722) Add ConsumerGroupPartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-16722: - Description: Adds the interface

[jira] [Updated] (KAFKA-16722) Add ConsumerGroupPartitionAssignor interface

[ https://issues.apache.org/jira/browse/KAFKA-16722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-16722: - Summary: Add ConsumerGroupPartitionAssignor interface (was: Add

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

[ https://issues.apache.org/jira/browse/KAFKA-16722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-16722: - Fix Version/s: 3.8.0 > Add ConsumerGroupPartitionAssignor and

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

[ https://issues.apache.org/jira/browse/KAFKA-16722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-16722: - Description: Adds the interfaces

[jira] [Commented] (KAFKA-16759) Invalid client telemetry transition on consumer close

[ https://issues.apache.org/jira/browse/KAFKA-16759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846360#comment-17846360 ] Andrew Schofield commented on KAFKA-16759: -- Analysing the transitions, the invalid transition

[jira] [Created] (KAFKA-16759) Invalid client telemetry transition on consumer close

Andrew Schofield created KAFKA-16759: Summary: Invalid client telemetry transition on consumer close Key: KAFKA-16759 URL: https://issues.apache.org/jira/browse/KAFKA-16759 Project: Kafka

[jira] [Commented] (KAFKA-16245) DescribeConsumerGroupTest failing

[ https://issues.apache.org/jira/browse/KAFKA-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17846018#comment-17846018 ] Andrew Schofield commented on KAFKA-16245: -- The original problem causing this issue was

[jira] [Commented] (KAFKA-16245) DescribeConsumerGroupTest failing

[ https://issues.apache.org/jira/browse/KAFKA-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17845953#comment-17845953 ] Andrew Schofield commented on KAFKA-16245: -- Still flaky. > DescribeConsumerGroupTest failing >

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

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

[jira] [Resolved] (KAFKA-16676) Security docs missing RPCs from KIP-714 and KIP-1000

[ https://issues.apache.org/jira/browse/KAFKA-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-16676. -- Resolution: Fixed > Security docs missing RPCs from KIP-714 and KIP-1000 >

[jira] [Created] (KAFKA-16676) Security docs missing RPCs from KIP-714 and KIP-1000

Andrew Schofield created KAFKA-16676: Summary: Security docs missing RPCs from KIP-714 and KIP-1000 Key: KAFKA-16676 URL: https://issues.apache.org/jira/browse/KAFKA-16676 Project: Kafka

[jira] [Commented] (KAFKA-16657) KIP-848 does not work well on Zookeeper Mode

[ https://issues.apache.org/jira/browse/KAFKA-16657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843236#comment-17843236 ] Andrew Schofield commented on KAFKA-16657: -- Ah, sorry for the jargon :) Apache Kafka = AK. The

[jira] [Commented] (KAFKA-16657) KIP-848 does not work well on Zookeeper Mode

[ https://issues.apache.org/jira/browse/KAFKA-16657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843227#comment-17843227 ] Andrew Schofield commented on KAFKA-16657: -- I just checked the KIP and I don't think it says

[jira] [Commented] (KAFKA-16514) Kafka Streams: stream.close(CloseOptions) does not respect options.leaveGroup flag.

[ https://issues.apache.org/jira/browse/KAFKA-16514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843121#comment-17843121 ] Andrew Schofield commented on KAFKA-16514: -- I agree that a KIP for extending Consumer.close is

[jira] [Commented] (KAFKA-16657) KIP-848 does not work well on Zookeeper Mode

[ https://issues.apache.org/jira/browse/KAFKA-16657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17843119#comment-17843119 ] Andrew Schofield commented on KAFKA-16657: -- My understanding is that the new consumer group

[jira] [Assigned] (KAFKA-16608) AsyncKafkaConsumer doesn't honour interrupted thread status on KafkaConsumer.poll(Duration)

[ https://issues.apache.org/jira/browse/KAFKA-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-16608: Assignee: Andrew Schofield > AsyncKafkaConsumer doesn't honour interrupted

[jira] [Created] (KAFKA-16608) AsyncKafkaConsumer doesn't honour interrupted thread status on KafkaConsumer.poll(Duration)

Andrew Schofield created KAFKA-16608: Summary: AsyncKafkaConsumer doesn't honour interrupted thread status on KafkaConsumer.poll(Duration) Key: KAFKA-16608 URL:

[jira] [Commented] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831197#comment-17831197 ] Andrew Schofield commented on KAFKA-15558: -- I was referring to the way that there is

[jira] [Commented] (KAFKA-16319) Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers

[ https://issues.apache.org/jira/browse/KAFKA-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823755#comment-17823755 ] Andrew Schofield commented on KAFKA-16319: -- No worries. My initial assessment was incorrect.

[jira] [Commented] (KAFKA-16319) Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers

[ https://issues.apache.org/jira/browse/KAFKA-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823706#comment-17823706 ] Andrew Schofield commented on KAFKA-16319: -- I have reproduced it. Certainly fails like this on

[jira] [Commented] (KAFKA-16319) Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers

[ https://issues.apache.org/jira/browse/KAFKA-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823653#comment-17823653 ] Andrew Schofield commented on KAFKA-16319: -- [~alexeyasf] How do you get it to do that? Do you

[jira] [Commented] (KAFKA-16319) Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers

[ https://issues.apache.org/jira/browse/KAFKA-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823276#comment-17823276 ] Andrew Schofield commented on KAFKA-16319: -- With an AK 3.7 client, I see that the DeleteRecords

[jira] [Assigned] (KAFKA-16319) Wrong broker destinations for DeleteRecords requests when more than one topic is involved and the topics/partitions are led by different brokers

[ https://issues.apache.org/jira/browse/KAFKA-16319?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-16319: Assignee: Andrew Schofield > Wrong broker destinations for DeleteRecords

[jira] [Assigned] (KAFKA-16245) DescribeConsumerGroupTest failing

[ https://issues.apache.org/jira/browse/KAFKA-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-16245: Assignee: Andrew Schofield > DescribeConsumerGroupTest failing >

[jira] [Commented] (KAFKA-16245) DescribeConsumerGroupTest failing

[ https://issues.apache.org/jira/browse/KAFKA-16245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17823002#comment-17823002 ] Andrew Schofield commented on KAFKA-16245: -- I see a couple of failures in my testing, one of

[jira] [Created] (KAFKA-16261) MembershipManagerImpl.updateSubscription fails if already empty subscription

Andrew Schofield created KAFKA-16261: Summary: MembershipManagerImpl.updateSubscription fails if already empty subscription Key: KAFKA-16261 URL: https://issues.apache.org/jira/browse/KAFKA-16261

[jira] [Created] (KAFKA-16243) Idle kafka-console-consumer with new consumer group protocol preemptively leaves group

Andrew Schofield created KAFKA-16243: Summary: Idle kafka-console-consumer with new consumer group protocol preemptively leaves group Key: KAFKA-16243 URL: https://issues.apache.org/jira/browse/KAFKA-16243

[jira] [Commented] (KAFKA-1837) Metadata record future never returns on get call after producer is stopped and messages can't be sent

[ https://issues.apache.org/jira/browse/KAFKA-1837?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816444#comment-17816444 ] Andrew Schofield commented on KAFKA-1837: - Initial testing seems to show that the current Kafka

[jira] [Commented] (KAFKA-8750) Utils#murmur2() method switch case block don't have break

[ https://issues.apache.org/jira/browse/KAFKA-8750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816390#comment-17816390 ] Andrew Schofield commented on KAFKA-8750: - I've reviewed the code and also a bunch of other

[jira] [Commented] (KAFKA-14041) Avoid the keyword var for a variable declaration in ConfigTransformer

[ https://issues.apache.org/jira/browse/KAFKA-14041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17816389#comment-17816389 ] Andrew Schofield commented on KAFKA-14041: -- While strictly speaking this is not a problem, I

[jira] [Assigned] (KAFKA-14041) Avoid the keyword var for a variable declaration in ConfigTransformer

[ https://issues.apache.org/jira/browse/KAFKA-14041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-14041: Assignee: Andrew Schofield > Avoid the keyword var for a variable declaration in

[jira] [Resolved] (KAFKA-8606) Provide a method to fetch committed offsets for a collection of TopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-8606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-8606. - Fix Version/s: 2.4.0 Resolution: Fixed Method added in AK 2.4. > Provide a

[jira] [Created] (KAFKA-16184) Flaky test - testAlterReplicaLogDirs(String).quorum=kraft – kafka.api.PlaintextAdminIntegrationTest

Andrew Schofield created KAFKA-16184: Summary: Flaky test - testAlterReplicaLogDirs(String).quorum=kraft – kafka.api.PlaintextAdminIntegrationTest Key: KAFKA-16184 URL:

[jira] [Created] (KAFKA-16183) Flaky test - testMetricsDuringTopicCreateDelete(String).quorum=zk – kafka.integration.MetricsDuringTopicCreationDeletionTest

Andrew Schofield created KAFKA-16183: Summary: Flaky test - testMetricsDuringTopicCreateDelete(String).quorum=zk – kafka.integration.MetricsDuringTopicCreationDeletionTest Key: KAFKA-16183 URL:

[jira] [Created] (KAFKA-16182) Flaky test - testClientInstanceId() - org.apache.kafka.clients.admin.KafkaAdminClientTest

Andrew Schofield created KAFKA-16182: Summary: Flaky test - testClientInstanceId() - org.apache.kafka.clients.admin.KafkaAdminClientTest Key: KAFKA-16182 URL: https://issues.apache.org/jira/browse/KAFKA-16182

[jira] [Updated] (KAFKA-16092) Queues for Kafka

[ https://issues.apache.org/jira/browse/KAFKA-16092?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-16092: - Labels: queues-for-kafka (was: ) > Queues for Kafka > > >

[jira] [Created] (KAFKA-16137) ListClientMetricsResourcesResponse definition is missing field descriptions

Andrew Schofield created KAFKA-16137: Summary: ListClientMetricsResourcesResponse definition is missing field descriptions Key: KAFKA-16137 URL: https://issues.apache.org/jira/browse/KAFKA-16137

[jira] [Assigned] (KAFKA-16137) ListClientMetricsResourcesResponse definition is missing field descriptions

[ https://issues.apache.org/jira/browse/KAFKA-16137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-16137: Assignee: Andrew Schofield > ListClientMetricsResourcesResponse definition is

[jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription

[ https://issues.apache.org/jira/browse/KAFKA-15561?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17805964#comment-17805964 ] Andrew Schofield commented on KAFKA-15561: -- [~phuctran] Yes, exactly. These classes are

[jira] [Created] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer

Andrew Schofield created KAFKA-16104: Summary: Enable additional PlaintextConsumerTest tests for new consumer Key: KAFKA-16104 URL: https://issues.apache.org/jira/browse/KAFKA-16104 Project:

[jira] [Created] (KAFKA-16100) Consistent handling of timeouts and responses for new consumer ApplicationEvents

Andrew Schofield created KAFKA-16100: Summary: Consistent handling of timeouts and responses for new consumer ApplicationEvents Key: KAFKA-16100 URL: https://issues.apache.org/jira/browse/KAFKA-16100

[jira] [Created] (KAFKA-16099) Handle timeouts for AsyncKafkaConsumer.commitSync

Andrew Schofield created KAFKA-16099: Summary: Handle timeouts for AsyncKafkaConsumer.commitSync Key: KAFKA-16099 URL: https://issues.apache.org/jira/browse/KAFKA-16099 Project: Kafka

[jira] [Updated] (KAFKA-15553) Review committed offset refresh logic

[ https://issues.apache.org/jira/browse/KAFKA-15553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-15553: - Description: >From the existing comment: If there are any partitions which do not have

[jira] [Created] (KAFKA-16092) Queues for Kafka

Andrew Schofield created KAFKA-16092: Summary: Queues for Kafka Key: KAFKA-16092 URL: https://issues.apache.org/jira/browse/KAFKA-16092 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions()

[ https://issues.apache.org/jira/browse/KAFKA-15558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17804324#comment-17804324 ] Andrew Schofield commented on KAFKA-15558: -- [~phuctran] I think my PR was in the same area and

[jira] [Resolved] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15775. -- Resolution: Fixed > Implement listTopics() and partitionFor() for the

[jira] [Assigned] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer

[ https://issues.apache.org/jira/browse/KAFKA-15775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-15775: Assignee: Andrew Schofield > Implement listTopics() and partitionFor() for the

[jira] [Resolved] (KAFKA-15986) New consumer group protocol integration test failures

[ https://issues.apache.org/jira/browse/KAFKA-15986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15986. -- Resolution: Fixed > New consumer group protocol integration test failures >

[jira] [Created] (KAFKA-15986) New consumer group protocol integration test failures

Andrew Schofield created KAFKA-15986: Summary: New consumer group protocol integration test failures Key: KAFKA-15986 URL: https://issues.apache.org/jira/browse/KAFKA-15986 Project: Kafka

[jira] [Resolved] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")

[ https://issues.apache.org/jira/browse/KAFKA-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15932. -- Resolution: Fixed > Flaky test -

[jira] [Created] (KAFKA-15978) New consumer sends OffsetCommit with empty member ID

Andrew Schofield created KAFKA-15978: Summary: New consumer sends OffsetCommit with empty member ID Key: KAFKA-15978 URL: https://issues.apache.org/jira/browse/KAFKA-15978 Project: Kafka

[jira] [Resolved] (KAFKA-15533) Ensure HeartbeatRequestManager only send out some fields once

[ https://issues.apache.org/jira/browse/KAFKA-15533?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15533. -- Resolution: Resolved Already resolved > Ensure HeartbeatRequestManager only send out

[jira] [Created] (KAFKA-15971) Re-enable consumer integration tests for new consumer

Andrew Schofield created KAFKA-15971: Summary: Re-enable consumer integration tests for new consumer Key: KAFKA-15971 URL: https://issues.apache.org/jira/browse/KAFKA-15971 Project: Kafka

[jira] [Resolved] (KAFKA-15966) Test failure - ClassCastException in ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy

[ https://issues.apache.org/jira/browse/KAFKA-15966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15966. -- Resolution: Duplicate Just fixed by https://github.com/apache/kafka/pull/14895 >

[jira] [Resolved] (KAFKA-15953) Refactor polling delays

[ https://issues.apache.org/jira/browse/KAFKA-15953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15953. -- Resolution: Fixed > Refactor polling delays > --- > >

[jira] [Updated] (KAFKA-15966) Test failure - ClassCastException in ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy

[ https://issues.apache.org/jira/browse/KAFKA-15966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-15966: - Labels: test-failure (was: ) > Test failure - ClassCastException in >

[jira] [Created] (KAFKA-15966) Test failure - ClassCastException in ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy

Andrew Schofield created KAFKA-15966: Summary: Test failure - ClassCastException in ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy Key: KAFKA-15966 URL:

[jira] [Created] (KAFKA-15953) Refactor polling delays

Andrew Schofield created KAFKA-15953: Summary: Refactor polling delays Key: KAFKA-15953 URL: https://issues.apache.org/jira/browse/KAFKA-15953 Project: Kafka Issue Type: Sub-task

[jira] [Resolved] (KAFKA-15890) Consumer.poll with long timeout unaware of assigned partitions

[ https://issues.apache.org/jira/browse/KAFKA-15890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15890. -- Resolution: Fixed > Consumer.poll with long timeout unaware of assigned partitions >

[jira] [Resolved] (KAFKA-15842) Correct handling of KafkaConsumer.committed for new consumer

[ https://issues.apache.org/jira/browse/KAFKA-15842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15842. -- Resolution: Fixed > Correct handling of KafkaConsumer.committed for new consumer >

[jira] [Created] (KAFKA-15945) Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest

Andrew Schofield created KAFKA-15945: Summary: Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest Key: KAFKA-15945 URL:

[jira] [Created] (KAFKA-15944) Flaky test - verifyStore[cache=false, log=true, supplier=ROCKS_KV, kind=DSL] – org.apache.kafka.streams.integration.PositionRestartIntegrationTest

Andrew Schofield created KAFKA-15944: Summary: Flaky test - verifyStore[cache=false, log=true, supplier=ROCKS_KV, kind=DSL] – org.apache.kafka.streams.integration.PositionRestartIntegrationTest Key: KAFKA-15944

[jira] [Created] (KAFKA-15943) Flaky test - testHighWaterMarkAfterPartitionReassignment(String).quorum=kraft – org.apache.kafka.tools.reassign.ReassignPartitionsIntegrationTest

Andrew Schofield created KAFKA-15943: Summary: Flaky test - testHighWaterMarkAfterPartitionReassignment(String).quorum=kraft – org.apache.kafka.tools.reassign.ReassignPartitionsIntegrationTest Key: KAFKA-15943

[jira] [Commented] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")

[ https://issues.apache.org/jira/browse/KAFKA-15932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17791137#comment-17791137 ] Andrew Schofield commented on KAFKA-15932: -- I have confirmed that the test is doing its job and

[jira] [Created] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer")

Andrew Schofield created KAFKA-15932: Summary: Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer") Key: KAFKA-15932 URL: https://issues.apache.org/jira/browse/KAFKA-15932

[jira] [Resolved] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client

[ https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15840. -- Resolution: Duplicate > Correct initialization of ConsumerGroupHeartbeat by client >

[jira] [Commented] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client

[ https://issues.apache.org/jira/browse/KAFKA-15840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17789069#comment-17789069 ] Andrew Schofield commented on KAFKA-15840: -- Fixed by KAFKA-15574. > Correct initialization of

[jira] [Created] (KAFKA-15890) kafka-console-consumer.sh problems with new consumer

Andrew Schofield created KAFKA-15890: Summary: kafka-console-consumer.sh problems with new consumer Key: KAFKA-15890 URL: https://issues.apache.org/jira/browse/KAFKA-15890 Project: Kafka

[jira] [Created] (KAFKA-15871) Implement kafka-client-metrics.sh tool

Andrew Schofield created KAFKA-15871: Summary: Implement kafka-client-metrics.sh tool Key: KAFKA-15871 URL: https://issues.apache.org/jira/browse/KAFKA-15871 Project: Kafka Issue Type:

[jira] [Resolved] (KAFKA-15837) Throw error on use of Consumer.poll(long timeout)

[ https://issues.apache.org/jira/browse/KAFKA-15837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-15837. -- Resolution: Fixed > Throw error on use of Consumer.poll(long timeout) >

[jira] [Assigned] (KAFKA-15837) Throw error on use of Consumer.poll(long timeout)

[ https://issues.apache.org/jira/browse/KAFKA-15837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-15837: Assignee: Andrew Schofield (was: Kirk True) > Throw error on use of

[jira] [Commented] (KAFKA-15836) KafkaConsumer subscribes to multiple topics does not respect max.poll.records

[ https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788314#comment-17788314 ] Andrew Schofield commented on KAFKA-15836: -- I think so. Waiting for [~pnee] to confirm. >

[jira] [Commented] (KAFKA-15836) KafkaConsumer subscribes to multiple topics does not respect max.poll.records

[ https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17788084#comment-17788084 ] Andrew Schofield commented on KAFKA-15836: -- PR merged to trunk. > KafkaConsumer subscribes to

[jira] [Updated] (KAFKA-15836) KafkaConsumer subscribes to multiple topics does not respect max.poll.records

[ https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield updated KAFKA-15836: - Fix Version/s: 3.7.0 (was: 3.6.1) Affects Version/s:

[jira] [Commented] (KAFKA-15836) KafkaConsumer subscribes to multiple topics does not respect max.poll.records

[ https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787243#comment-17787243 ] Andrew Schofield commented on KAFKA-15836: -- I would say that it's not applicable to 3.6. From

[jira] [Commented] (KAFKA-15836) KafkaConsumer subscribes to multiple topics does not respect max.poll.records

[ https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17787128#comment-17787128 ] Andrew Schofield commented on KAFKA-15836: -- Yes, I would say so. I think I'll have a PR on

[jira] [Assigned] (KAFKA-15836) KafkaConsumer subscribes to multiple topics does not respect max.poll.records

[ https://issues.apache.org/jira/browse/KAFKA-15836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-15836: Assignee: Andrew Schofield (was: Kirk True) > KafkaConsumer subscribes to

[jira] [Created] (KAFKA-15842) Correct handling of KafkaConsumer.committed for new consumer

Andrew Schofield created KAFKA-15842: Summary: Correct handling of KafkaConsumer.committed for new consumer Key: KAFKA-15842 URL: https://issues.apache.org/jira/browse/KAFKA-15842 Project: Kafka

  1   2   >