jira@kafka.apache.org, 2023-12

You are viewing a plain text version of this content. The canonical link for it is here.

- Re: [PR] KAFKA-15448: Streams Standby Update Listener (KIP-988) [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2023/12/01 00:00:17 UTC, 7 replies.
- [jira] [Resolved] (KAFKA-15527) Add reverseRange and reverseAll query over kv-store in IQv2 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/01 00:07:00 UTC, 0 replies.
- [PR] MINOR: fix BrokerRegistrationRequest broken by KAFKA-15922 [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2023/12/01 00:38:31 UTC, 2 replies.
- Re: [PR] MINOR: Upgrade to gradle 8.5 [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2023/12/01 00:47:27 UTC, 2 replies.
- Re: [PR] KAFKA-15363: Broker log directory failure changes [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2023/12/01 00:47:40 UTC, 20 replies.
- Re: [PR] KAFKA-15890: Consumer.poll with long timeout unaware of assigned partitions [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2023/12/01 00:47:55 UTC, 4 replies.
- [PR] MINOR: Fix flaky test RefreshingHttpsJwksTest.testBasicScheduleRefresh [kafka] - posted by "splett2 (via GitHub)" <gi...@apache.org> on 2023/12/01 01:16:40 UTC, 13 replies.
- [PR] MINOR: cleanup internal Iterator impl [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/01 01:34:13 UTC, 1 replies.
- Re: [PR] KAFKA-15347: add support for 'single key multi timestamp' IQs with versioned state stores (KIP-968) [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/01 01:53:44 UTC, 21 replies.
- [PR] MINOR: Fix flaky `DescribeClusterRequestTest.testDescribeClusterRequestIncludingClusterAuthorizedOperations` [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2023/12/01 02:08:41 UTC, 2 replies.
- [PR] improve TopicCommandIntegrationTest to be less flaky [kafka] - posted by "Owen-CH-Leung (via GitHub)" <gi...@apache.org> on 2023/12/01 02:58:13 UTC, 5 replies.
- Re: [PR] KAFKA-14725: Interrupt source task poll thread when cancelled [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/01 03:33:13 UTC, 1 replies.
- Re: [PR] ctr-staging-testing-draft [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/01 03:33:27 UTC, 1 replies.
- Re: [PR] KAFKA-15663, KAFKA-15794: Telemetry reporter and request handling (KIP-714) [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/01 05:04:05 UTC, 79 replies.
- Re: [PR] KAFKA-15901: Client changes for registering telemetry and API calls (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2023/12/01 05:28:02 UTC, 13 replies.
- Re: [PR] KAFKA-14516: [2/N] New Group Coordinator IT for Static Member Replacement [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2023/12/01 07:03:30 UTC, 8 replies.
- Re: [PR] KAFKA-15489: resign leadership when no fetch from majority voters [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/01 07:04:57 UTC, 0 replies.
- [PR] HOTFIX: Fix BrokerRegistrationRequestTest [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/01 07:08:14 UTC, 4 replies.
- [PR] Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest [kafka] - posted by "atu-sharm (via GitHub)" <gi...@apache.org> on 2023/12/01 07:09:30 UTC, 0 replies.
- Re: [PR] KAFKA-15830: Add telemetry API handling (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2023/12/01 07:27:03 UTC, 18 replies.
- Re: [PR] KAFKA-15831: KIP-1000 protocol and admin client [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/01 07:31:53 UTC, 9 replies.
- Re: [PR] MINOR: Disable FetchFromFollowerIntegrationTest.testRackAwareRangeAssignor [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 08:05:48 UTC, 0 replies.
- Re: [PR] KAFKA-15695: Update the local log start offset of a log after rebuilding the auxiliary state [kafka] - posted by "satishd (via GitHub)" <gi...@apache.org> on 2023/12/01 08:24:12 UTC, 4 replies.
- Re: [PR] KAFKA-15276: Implement event plumbing for ConsumerRebalanceListener callbacks [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 08:43:34 UTC, 95 replies.
- [jira] [Commented] (KAFKA-15945) Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest - posted by "Atul Sharma (Jira)" <ji...@apache.org> on 2023/12/01 08:44:00 UTC, 0 replies.
- Re: [PR] KAFKA-15945 : Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest [kafka] - posted by "atu-sharm (via GitHub)" <gi...@apache.org> on 2023/12/01 08:58:09 UTC, 9 replies.
- Re: [PR] KAFKA-14509: [2/2] Implement server side logic for ConsumerGroupDescribe API [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 09:17:08 UTC, 0 replies.
- Re: [PR] KAFKA-15574; [2/N]: Client state machine updates [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 09:21:18 UTC, 18 replies.
- Re: [PR] KAFKA-14509: [2/N] Implement server side logic for ConsumerGroupDescribe API [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 09:25:54 UTC, 2 replies.
- Re: [PR] KAFKA-14987 [2/2]; customize retry backoff for group/offsets expiration [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 09:42:20 UTC, 4 replies.
- [jira] [Created] (KAFKA-15952) Create public doc for telemetry state transition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/01 09:57:00 UTC, 0 replies.
- Re: [PR] KAFKA-15662: Add support for clientInstanceIds in Kafka Stream [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/01 11:47:07 UTC, 30 replies.
- Re: [PR] KAFKA-15361: Process and persist dir info with broker registration [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/01 12:02:03 UTC, 46 replies.
- [jira] [Commented] (KAFKA-15140) Improve TopicCommandIntegrationTest to be less flaky - posted by "Owen C.H. Leung (Jira)" <ji...@apache.org> on 2023/12/01 12:16:00 UTC, 1 replies.
- Re: [PR] KAFKA-14412: Better Rocks column family management [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2023/12/01 12:18:30 UTC, 12 replies.
- Re: [PR] KAFKA-14412: Generalise over RocksDB WriteBatch [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2023/12/01 12:18:38 UTC, 11 replies.
- Re: [PR] MINOR: Add junit properties to display parameterized test names [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/01 12:19:15 UTC, 18 replies.
- Re: [PR] KAFKA-15910: New group coordinator needs to generate snapshots while loading [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 12:51:47 UTC, 8 replies.
- Re: [PR] KAFKA-15629: Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 13:18:23 UTC, 0 replies.
- Re: [PR] KAFKA-15280: Implement client support for KIP-848 server-side assignors [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/01 13:32:44 UTC, 12 replies.
- Re: [PR] KAFKA-15842: Correct handling of KafkaConsumer.committed for new consumer [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/01 13:36:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15842) Correct handling of KafkaConsumer.committed for new consumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/01 13:40:00 UTC, 0 replies.
- Re: [PR] KAFKA-15281: Implement the groupMetadata Consumer API [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/01 14:04:42 UTC, 28 replies.
- [PR] HOTFIX: fix ConsistencyVectorIntegrationTest failure [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/01 14:16:09 UTC, 6 replies.
- [jira] [Updated] (KAFKA-15891) Flaky test: testResetSinkConnectorOffsetsOverriddenConsumerGroupId – org.apache.kafka.connect.integration.OffsetsApiIntegrationTest - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/01 14:28:00 UTC, 0 replies.
- Re: [PR] KAFKA-14133: Migrate ProcessorStateManagerTest and StreamThreadTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2023/12/01 14:33:06 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15890) Consumer.poll with long timeout unaware of assigned partitions - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/01 14:43:00 UTC, 0 replies.
- Re: [PR] KAFKA-15426: Process and persist directory assignments [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/01 14:44:45 UTC, 7 replies.
- [jira] [Created] (KAFKA-15953) Refactor polling delays - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/01 14:48:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/01 14:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/01 14:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15955) Migrating ZK brokers send dir assignments - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2023/12/01 15:48:00 UTC, 0 replies.
- [PR] MINOR: Add @Timeout annotation to consumer integration tests [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/01 15:50:19 UTC, 3 replies.
- [PR] KAFKA-15953: Refactor polling delays [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/01 15:57:30 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-15955) Migrating ZK brokers send dir assignments - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2023/12/01 16:06:00 UTC, 0 replies.
- Re: [PR] MINOR: disable test_transactions with new group coordinator [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/01 16:46:42 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/01 17:51:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/01 17:51:00 UTC, 2 replies.
- Re: [PR] KAFKA-15690: Fix restoring tasks on partition loss, flaky EosIntegrationTest [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/01 17:57:30 UTC, 0 replies.
- [PR] KAKFA-15629: Update upgrade-guide.html for TimestampedKeyQuery and TimestampedRangeQuery [kafka] - posted by "hanyuzheng7 (via GitHub)" <gi...@apache.org> on 2023/12/01 17:57:51 UTC, 10 replies.
- Re: [PR] KAFKA-15061; CoordinatorPartitionWriter should reuse buffer [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2023/12/01 21:10:32 UTC, 10 replies.
- Re: [PR] MINOR: Ensure that DisplayName is set in all parameterized tests [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2023/12/01 21:29:58 UTC, 1 replies.
- [jira] [Created] (KAFKA-15956) MetadataShell must take the directory lock when reading - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/01 22:34:00 UTC, 0 replies.
- Re: [PR] KAFKA-14585: 1st part : Java versions for metadata/broker and updated LogConfig [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2023/12/01 22:35:44 UTC, 1 replies.
- [PR] KAFKA-15956: MetadataShell must take the log directory lock when reading [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2023/12/01 23:10:31 UTC, 8 replies.
- [jira] [Created] (KAFKA-15957) ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy broken - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/01 23:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15957) ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy broken - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/01 23:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15957) ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy broken - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/02 00:25:00 UTC, 0 replies.
- [PR] errorHandling [kafka] - posted by "rayalatrinadh (via GitHub)" <gi...@apache.org> on 2023/12/02 01:27:25 UTC, 2 replies.
- [PR] improve logging around broker/NetworkClient connectivity [kafka] - posted by "rayalatrinadh (via GitHub)" <gi...@apache.org> on 2023/12/02 02:12:00 UTC, 3 replies.
- Re: [PR] Kafka-14748: Relax non-null FK left-join requirement [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2023/12/02 02:27:29 UTC, 5 replies.
- Re: [PR] KAFKA-14438: Throw error when consumer configured with empty/whitespace-only group.id for AsyncKafkaConsumer [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2023/12/02 03:44:56 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer") - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/02 04:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-13152: Kip 770 buffer size fix [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2023/12/02 04:35:22 UTC, 0 replies.
- [jira] [Created] (KAFKA-15958) Add tests to validate telemetry requests with different version - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/02 05:55:00 UTC, 0 replies.
- Re: [PR] KAFKA-15445: Add JVM Docker image [kafka] - posted by "omkreddy (via GitHub)" <gi...@apache.org> on 2023/12/02 08:39:49 UTC, 13 replies.
- [jira] [Updated] (KAFKA-15364) Handle log directory failure in the Controller - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2023/12/02 15:51:00 UTC, 0 replies.
- [PR] KAFKA-15364: Handle log directory failure in the Controller [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/02 16:27:44 UTC, 15 replies.
- Re: [PR] [WIP] MINOR: Find threads leak2 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/03 03:33:10 UTC, 0 replies.
- Re: [PR] KAFKA-15801: improve Kafka broker/NetworkClient logging for connectiv… [kafka] - posted by "Joker-5 (via GitHub)" <gi...@apache.org> on 2023/12/03 05:38:33 UTC, 3 replies.
- [jira] [Created] (KAFKA-15959) Replace byte handling classes with synchronized methods - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2023/12/03 05:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15959) Replace byte handling classes with synchronized methods - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2023/12/03 05:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15959) Replace byte handling classes with synchronized methods - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2023/12/03 05:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15950) CommunicationEvent should be scheduled with EarliestDeadlineFunction - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2023/12/03 11:06:00 UTC, 0 replies.
- [PR] KAFKA-15950: Serialize broker heartbeat requests [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/03 11:11:39 UTC, 24 replies.
- Re: [PR] MINOR: Comment explaining test approach [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/03 11:12:25 UTC, 1 replies.
- [PR] Experimentally turn off consumer integration tests using new consumer [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/03 11:45:32 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2023/12/03 14:55:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15936) Flaky tests for class: ConnectorTopicsIntegrationTest - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2023/12/03 15:43:00 UTC, 0 replies.
- [PR] MINOR: Allow local-log segment deletion when log-start-offset incremented [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2023/12/03 16:15:56 UTC, 4 replies.
- [jira] [Updated] (KAFKA-15166) Add deletePartition API to the RemoteStorageManager - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2023/12/03 16:41:00 UTC, 1 replies.
- [PR] KAFKA-15527: Support ResultOrder to reverseRange and reverseAll query over kv-store in IQv2 [kafka] - posted by "hanyuzheng7 (via GitHub)" <gi...@apache.org> on 2023/12/03 17:24:34 UTC, 12 replies.
- [PR] KAFKA-15629: Support ResultOrder to TimestampedRangeQuery. [kafka] - posted by "hanyuzheng7 (via GitHub)" <gi...@apache.org> on 2023/12/03 17:53:37 UTC, 16 replies.
- [jira] [Created] (KAFKA-15960) Flaky test: testQuotaOverrideDelete(String).quorum=kraft – kafka.api.ClientIdQuotaTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/03 19:28:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15961) Flaky test: testTopicIdPersistsThroughControllerRestart() – kafka.controller.ControllerIntegrationTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/03 19:29:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15962) Flaky test: testAlterPartitionVersion2KeepWorkingWhenControllerDowngradeToPre28IBP() – kafka.controller.ControllerIntegrationTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/03 19:31:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15963) Flaky test: testBrokerHeartbeatDuringMigration [3] 3.6-IV0 – org.apache.kafka.controller.QuorumControllerTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/03 19:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15964) Flaky test: testHighAvailabilityTaskAssignorLargeNumConsumers – org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/03 19:33:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15965) Test failure: org.apache.kafka.common.requests.BrokerRegistrationRequestTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/03 19:55:00 UTC, 0 replies.
- Re: [PR] KAFKA-15922: Add a MetadataVersion for JBOD [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2023/12/03 20:14:37 UTC, 2 replies.
- [jira] [Created] (KAFKA-15966) Test failure - ClassCastException in ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/03 21:42:00 UTC, 0 replies.
- Re: [PR] KAFKA-15365: Broker-side replica management changes [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/03 21:42:00 UTC, 41 replies.
- [jira] [Updated] (KAFKA-15966) Test failure - ClassCastException in ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/03 21:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15953) Refactor polling delays - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/03 22:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-14438: Throw if async consumer configured with invalid group ID [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/03 22:11:44 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15966) Test failure - ClassCastException in ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/03 22:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-15795: Support fetch(fromKey, toKey, from, to) to WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2023/12/03 23:04:19 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15328) intra-broker partition reassignment triggers offline log dirs randomly - posted by "Maxime Thébault (Jira)" <ji...@apache.org> on 2023/12/04 00:05:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15957) ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy broken - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/04 01:25:00 UTC, 0 replies.
- Re: [PR] KAFKA-15818: ensure leave group on max poll interval [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/04 06:15:44 UTC, 52 replies.
- [jira] [Resolved] (KAFKA-14438) Throw error when consumer configured with empty/whitespace-only group.id for AsyncKafkaConsumer - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/04 08:01:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14438) Throw error when consumer configured with empty/whitespace-only group.id for AsyncKafkaConsumer - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/04 08:01:00 UTC, 0 replies.
- [PR] KAFKA-9545 Fix Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` [kafka] - posted by "ashwinpankaj (via GitHub)" <gi...@apache.org> on 2023/12/04 08:33:12 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15690) EosIntegrationTest is flaky. - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/04 08:51:00 UTC, 0 replies.
- Re: [PR] test changes [kafka] - posted by "sambhav-jain-16 (via GitHub)" <gi...@apache.org> on 2023/12/04 08:58:44 UTC, 0 replies.
- Re: [PR] KAFKA-15883: Implement RemoteCopyLagBytes [kafka] - posted by "satishd (via GitHub)" <gi...@apache.org> on 2023/12/04 09:15:26 UTC, 28 replies.
- [jira] [Created] (KAFKA-15967) Fix revocation in reconcilation logic - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/04 09:39:00 UTC, 0 replies.
- Re: [PR] KAFKA-12216; Improve flaky test reporting [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/04 09:51:04 UTC, 3 replies.
- Re: [PR] MINOR: Upgrade jetty to 9.4.53.v20231009 [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2023/12/04 09:53:41 UTC, 1 replies.
- [PR] KAFKA-14516: [3/N] New Group Coordinator IT for Static Member removed from Group upon Session timeout expiry [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2023/12/04 10:20:14 UTC, 5 replies.
- [jira] [Commented] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/04 12:45:00 UTC, 2 replies.
- [PR] KAFKA-15932: Wait for responses in consumer operations [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/04 12:57:05 UTC, 13 replies.
- [jira] [Commented] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/04 13:50:00 UTC, 4 replies.
- [jira] [Comment Edited] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/04 13:51:00 UTC, 0 replies.
- [PR] MINOR: Fix ConsumerNetworkThread shutdown [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/04 14:04:07 UTC, 2 replies.
- [PR] MINOR: Various fixes in the docs [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/04 15:17:10 UTC, 9 replies.
- [jira] [Created] (KAFKA-15968) QuorumController does not treat CorruptRecordException as fatal - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/04 15:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15968) QuorumController does not treat CorruptRecordException as fatal - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/04 15:46:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-10840) Need way to catch auth issues in poll method of Java Kafka client - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/04 15:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15912) Parallelize conversion and transformation steps in Connect - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/04 16:05:00 UTC, 1 replies.
- [PR] MINOR: Enable auto-tick in AsyncKafkaConsumerTest [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/04 16:06:18 UTC, 2 replies.
- Re: [PR] KAFKA-15827: Prevent KafkaBasedLog subclasses from leaking passed-in clients [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2023/12/04 16:38:32 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-15358) QueuedReplicaToDirAssignments metric - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2023/12/04 16:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15969) Align RemoteStorageThreadPool metrics name with KIP-405 - posted by "Lixin Yao (Jira)" <ji...@apache.org> on 2023/12/04 17:09:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15965) Test failure: org.apache.kafka.common.requests.BrokerRegistrationRequestTest - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2023/12/04 17:26:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15970) KIP-951, port newly added tests in FetcherTest.java to FetchRequestManagerTest.ajva - posted by "Mayank Shekhar Narula (Jira)" <ji...@apache.org> on 2023/12/04 17:34:00 UTC, 0 replies.
- [PR] KAFKA-15970 Copy over KIP-951 tests in FetcherTest.java to FetchRequestManagerTest.java [kafka] - posted by "msn-tldr (via GitHub)" <gi...@apache.org> on 2023/12/04 17:37:11 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-15818) Implement max poll interval - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/04 17:40:00 UTC, 0 replies.
- Re: [PR] MINOR: Change test logging capture to per-test, reducing jenkins truncation [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/04 17:52:49 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15913) Remove excessive use of spy in ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/04 18:12:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15913) Remove excessive use of spy in ConsumerTestBuilder - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/04 18:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-15784: Ensure atomicity of in memory update and write when transactionally committing offsets [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/04 18:16:46 UTC, 69 replies.
- [jira] [Created] (KAFKA-15971) Re-enable consumer integration tests for new consumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/04 18:22:00 UTC, 0 replies.
- [jira] (KAFKA-15818) Implement max poll interval - posted by "Ashwini Sharma (Jira)" <ji...@apache.org> on 2023/12/04 18:29:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15818) Implement max poll interval - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/04 18:32:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-15533) Ensure HeartbeatRequestManager only send out some fields once - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/04 18:39:00 UTC, 0 replies.
- [PR] KAFKA-15760: Disable flaky test testTaskRequestWithOldStartMsGetsUpdated [kafka] - posted by "splett2 (via GitHub)" <gi...@apache.org> on 2023/12/04 20:05:40 UTC, 6 replies.
- Re: [PR] MINOR: Fix flaky test testRackAwareRangeAssignor [kafka] - posted by "splett2 (via GitHub)" <gi...@apache.org> on 2023/12/04 20:16:34 UTC, 1 replies.
- Re: [PR] KAFKA-13988: Enable replicating from latest offset with MirrorMaker 2 [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2023/12/04 20:51:28 UTC, 2 replies.
- Re: [PR] KAFKA-15563: Provide informative error messages when Connect REST requests time out [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2023/12/04 21:04:00 UTC, 8 replies.
- [jira] [Updated] (KAFKA-15645) Move ReplicationQuotasTestRig to tools - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/04 21:14:00 UTC, 0 replies.
- [PR] MINOR: fix bug where we weren't registering SnapshotEmitterMetrics [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2023/12/04 21:17:08 UTC, 3 replies.
- [PR] KAFKA-15968 Handle two specific ApiExceptions in EventHandlerExceptionInfo [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2023/12/04 21:38:14 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13988) Mirrormaker 2 auto.offset.reset=latest not working - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/04 21:51:00 UTC, 0 replies.
- [PR] KAFKA-00000 Handle consumer close [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/04 21:51:31 UTC, 3 replies.
- [PR] KAFKA-15022: tests for HA assignor [kafka] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2023/12/04 22:01:50 UTC, 0 replies.
- Re: [PR] KAFKA-15372: Reconfigure dedicated MM2 connectors after leadership change [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2023/12/04 22:11:56 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-9631) MockAdminClient doesn't handle CreateTopics optional fields - posted by "Eduardo Pinto (Jira)" <ji...@apache.org> on 2023/12/04 23:01:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9631) MockAdminClient doesn't handle CreateTopics optional fields - posted by "Eduardo Pinto (Jira)" <ji...@apache.org> on 2023/12/04 23:02:00 UTC, 0 replies.
- Re: [PR] KAFKA-9631: Fix support for optional fields in MockAdminClient [kafka] - posted by "efgpinto (via GitHub)" <gi...@apache.org> on 2023/12/04 23:03:14 UTC, 1 replies.
- Re: [PR] KAFKA-14505; [2/N] Implement TxnOffsetCommit API [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/04 23:04:30 UTC, 22 replies.
- [jira] [Commented] (KAFKA-6968) Call RebalanceListener in MockConsumer - posted by "Eduardo Pinto (Jira)" <ji...@apache.org> on 2023/12/04 23:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-6968) Call RebalanceListener in MockConsumer - posted by "Eduardo Pinto (Jira)" <ji...@apache.org> on 2023/12/04 23:06:00 UTC, 0 replies.
- Re: [PR] KAFKA-6968: Adds calls to listener on rebalance of MockConsumer [kafka] - posted by "efgpinto (via GitHub)" <gi...@apache.org> on 2023/12/04 23:06:06 UTC, 0 replies.
- Re: [PR] KAFKA-15022: introduce interface to control graph constructor [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/05 00:13:31 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-15866) Refactor OffsetFetchRequestState Error handling to be more consistent with OffsetCommitRequestState - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2023/12/05 03:27:00 UTC, 0 replies.
- Re: [PR] MINOR: Explain need to escape backslashes in rules [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/05 03:33:14 UTC, 1 replies.
- [PR] KAFKA-15866:Refactor OffsetFetchRequestState Error handling [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2023/12/05 03:52:27 UTC, 2 replies.
- Re: [PR] KAFKA-9545: Fix Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` [kafka] - posted by "ashwinpankaj (via GitHub)" <gi...@apache.org> on 2023/12/05 04:57:25 UTC, 4 replies.
- [jira] [Created] (KAFKA-15972) Add support to exclude labels in client telemetry - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/05 06:46:00 UTC, 0 replies.
- [PR] KAFKA-15972: Add support to exclude labels for telemetry metrics (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2023/12/05 06:57:40 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-15061) CoordinatorPartitionWriter should reuse buffer - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/05 07:58:00 UTC, 0 replies.
- Re: [PR] MINOR: Add Uniform assignor to the default config [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/05 08:32:53 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14245) Topic deleted during reassignment - posted by "Quang Nguyen (Jira)" <ji...@apache.org> on 2023/12/05 08:35:00 UTC, 1 replies.
- Re: [PR] KAFKA-15645 ReplicationQuotasTestRig rewritten in java [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/05 09:03:35 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15645) Move ReplicationQuotasTestRig to tools - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/05 09:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14595) Move ReassignPartitionsCommand to tools - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/05 09:05:00 UTC, 0 replies.
- [PR] KAFKA-15971: Re-enable consumer integration tests for new consumer [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/05 10:21:31 UTC, 11 replies.
- Re: [PR] Improve benchmark settings to speed up benchmarking [kafka] - posted by "borisssmidtCET (via GitHub)" <gi...@apache.org> on 2023/12/05 10:21:39 UTC, 16 replies.
- [jira] [Updated] (KAFKA-14133) Remaining EasyMock to Mockito tests - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2023/12/05 10:40:00 UTC, 0 replies.
- [PR] KAFKA-15871: kafka-client-metrics.sh [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/05 10:45:37 UTC, 8 replies.
- Re: [PR] KAFKA-14132; Replace EasyMock with Mockito in StandaloneHerderTest [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2023/12/05 11:49:58 UTC, 7 replies.
- Re: [PR] KAFKA-14683 Migrate #testStartPaused to Mockito [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2023/12/05 11:52:25 UTC, 0 replies.
- [PR] MINOR: fix zookeeper_migration_test system test in 3.5 [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/05 11:53:07 UTC, 1 replies.
- [PR] [MINOR-PR] Enable telemetry APIs and logs suppression (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2023/12/05 12:50:36 UTC, 3 replies.
- Re: [PR] MINOR: Expose earliest local timestamp via the GetOffsetShell [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2023/12/05 13:03:18 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15893) Bump MetadataVersion for directory assignments - posted by "Igor Soarez (Jira)" <ji...@apache.org> on 2023/12/05 13:22:00 UTC, 0 replies.
- Re: [PR] KAFKA-14589 ConsumerGroupCommand options and case classes rewritten [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2023/12/05 13:55:09 UTC, 4 replies.
- Re: [PR] KAFKA-15355: Message schema changes [kafka] - posted by "aiven-anton (via GitHub)" <gi...@apache.org> on 2023/12/05 14:28:11 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-15366) Log directory failure integration test - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/05 14:52:00 UTC, 0 replies.
- [PR] KAFKA-14133: Migrate stateManager mock in StoreChangelogReaderTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2023/12/05 15:14:23 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15831) List Client Metrics Configuration Resources - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2023/12/05 15:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15366) Log directory failure integration test - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/05 15:16:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15705) Add integration tests for Heartbeat API and GroupLeave API - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/05 15:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15366) Log directory failure integration test - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/05 15:21:00 UTC, 0 replies.
- [PR] Draft: Migrate async consumer tests to mocks [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/05 16:01:09 UTC, 0 replies.
- Re: [PR] KAFKA-14516: [3/3] New Group Coordinator IT for Static Member removed from Group upon Session timeout expiry [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2023/12/05 16:02:28 UTC, 2 replies.
- [jira] [Created] (KAFKA-15973) quota_test.py system tests are flaky - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/05 16:25:00 UTC, 0 replies.
- [PR] MINOR: ConsumerRebalanceListenerInvoker class and method visibility [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2023/12/05 16:29:56 UTC, 10 replies.
- Re: [PR] KAFKA-15102 (backport): Add release notes about the replication.policy.internal.topic.separator.enabled property for MirrorMaker 2 [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2023/12/05 17:07:20 UTC, 2 replies.
- [PR] MINOR: Add 3.6.1 to system tests [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/05 17:10:58 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-15968) QuorumController does not treat CorruptRecordException as fatal - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/05 18:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15974) Enforce that CompletableApplicationEvent has a timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/05 18:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15974) Enforce that CompletableApplicationEvent has a timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/05 18:35:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15974) Enforce that CompletableApplicationEvent has a timeout that is respected - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/05 18:35:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15974) Enforce that CompletableApplicationEvent has a timeout that is respected - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/05 18:37:00 UTC, 0 replies.
- [PR] KAFKA-15684: Support to describe all client metrics resources (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2023/12/05 20:09:10 UTC, 14 replies.
- Re: [PR] MINOR: fully encapsulate user restore listener in the DelegatingRestoreListener [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2023/12/05 21:32:42 UTC, 1 replies.
- [jira] [Created] (KAFKA-15975) Update kafka quickstart guide to no longer list ZK start first - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/05 21:36:00 UTC, 0 replies.
- Re: [PR] KAFKA-15816: Fix leaked sockets in clients tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/05 22:33:35 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15816) Typos in tests leak network sockets - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/05 22:36:00 UTC, 1 replies.
- Re: [PR] KAFKA-15696: Refactor AsyncConsumer close procedure [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2023/12/06 00:02:26 UTC, 8 replies.
- [PR] MINOR: register before touch in BrokerHeartbeatManager [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/06 00:18:06 UTC, 2 replies.
- Re: [PR] KAFKA-15720: KRaft support in DeleteTopicTest [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2023/12/06 02:22:51 UTC, 4 replies.
- [PR] Kafka 15662 kip 714 restore [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/06 02:29:15 UTC, 0 replies.
- Re: [PR] [MINOR] fix: Align LogContext setup for core components [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/06 03:33:07 UTC, 1 replies.
- Re: [PR] MINOR: Add missing versions to STs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/06 03:33:09 UTC, 0 replies.
- Re: [PR] KAFKA-15296: Allow offsets to be committed for filtered records when Exactly Once support is disabled [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/06 03:33:15 UTC, 0 replies.
- Re: [PR] IncrementalCooperativeAssignor#handleLostAssignments invokes logic for lost Assignments even when there are no Lost assignments [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/06 03:33:21 UTC, 0 replies.
- Re: [PR] KAFKA-15119:Support incremental syncTopicAcls in MirrorSourceConnector [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/06 03:33:26 UTC, 0 replies.
- Re: [PR] KAFKA-15018: Failing offset flush for EOS when secondary offset store writes fails for tombstone records [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/06 03:33:32 UTC, 4 replies.
- Re: [PR] KAFKA-14598: Fix flaky ConnectRestApiTest [kafka] - posted by "ashwinpankaj (via GitHub)" <gi...@apache.org> on 2023/12/06 03:49:49 UTC, 0 replies.
- Re: [PR] KAFKA-14585: Move StorageTool to tools [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/06 07:13:32 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-15911) KRaft quorum leader should make sure the follower fetch is making progress - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/06 07:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15751) KRaft support in BaseAdminIntegrationTest - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2023/12/06 07:42:00 UTC, 0 replies.
- [PR] Refactor closing consumer [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/06 08:09:38 UTC, 5 replies.
- Re: [PR] KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams [kafka] - posted by "ashmeet13 (via GitHub)" <gi...@apache.org> on 2023/12/06 08:34:08 UTC, 0 replies.
- Re: [PR] KAFKA-13950: Fix resource leak in error scenarios [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/06 08:34:10 UTC, 4 replies.
- [jira] [Commented] (KAFKA-15593) Add 3.6.0 to broker/client upgrade/compatibility tests - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/06 09:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15853) Move KafkaConfig to server module - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2023/12/06 09:56:00 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-15853) Move KafkaConfig to server module - posted by "Federico Valeri (Jira)" <ji...@apache.org> on 2023/12/06 09:56:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-15976) KIP-995: Allow users to specify initial offsets while creating connectors - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2023/12/06 10:15:00 UTC, 0 replies.
- Re: [PR] KAFKA-15875 Make Snapshot public [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2023/12/06 10:18:20 UTC, 0 replies.
- Re: [PR] KAFKA-15208: Upgrade Jackson dependencies to version 2.15.3 [kafka] - posted by "bmscomp (via GitHub)" <gi...@apache.org> on 2023/12/06 10:36:57 UTC, 5 replies.
- Re: [PR] KAFKA-15662: Add support for clientInstanceIds in Kafka Stream [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/06 11:01:10 UTC, 7 replies.
- Re: [PR] KAFKA-15970: Copy over KIP-951 tests in FetcherTest.java to FetchRequestManagerTest.java [kafka] - posted by "msn-tldr (via GitHub)" <gi...@apache.org> on 2023/12/06 13:15:21 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15879) Add documentation and examples for the Docker image - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/06 13:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15879) Add documentation for the Docker image - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/06 13:42:00 UTC, 0 replies.
- [PR] KAFKA-15879: Add documentation and examples for docker image [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/06 13:53:38 UTC, 10 replies.
- [jira] [Created] (KAFKA-15977) DelegationTokenEndToEndAuthorizationWithOwnerTest leaks threads - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/06 14:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15977) DelegationTokenEndToEndAuthorizationWithOwnerTest leaks threads - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/06 14:15:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15977) DelegationTokenEndToEndAuthorizationWithOwnerTest leaks threads - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/06 14:31:00 UTC, 0 replies.
- [PR] KAFKA-15977: Fix leak in DelegationTokenEndToEndAuthorizationWithOwnerTest [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/06 14:32:08 UTC, 2 replies.
- [PR] KAFKA-15903: Add Github Actions Workflow for RC Docker Image [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/06 14:41:16 UTC, 1 replies.
- [PR] KAFKA-15880: Add Github Actions Workflow for promoting docker image [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/06 14:45:08 UTC, 1 replies.
- [jira] [Created] (KAFKA-15978) New consumer sends OffsetCommit with empty member ID - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/06 15:11:00 UTC, 0 replies.
- [PR] KAFKA-15358: Added QueuedReplicaToDirAssignments metric [kafka] - posted by "mwesterby (via GitHub)" <gi...@apache.org> on 2023/12/06 15:17:52 UTC, 9 replies.
- [PR] MINOR: start/stop channelManager properly in AssignmentsManager [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/06 15:39:52 UTC, 3 replies.
- [PR] MINOR: Fix flaky test testInvalidGroupId [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/06 15:45:18 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15347) Single-Key_multi-timestamp IQs with versioned state stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15346) Single-Key_single-timestamp IQs with versioned state stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15348) Range IQs with versioned state stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15347) Single-Key_multi-timestamp IQs with versioned state stores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-15022: tests for HA assignor and StickyTaskAssignor [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/06 16:12:50 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15026) Implement min-cost flow balancing tasks for same subtopology - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15022) Support rack aware task assignment in Kafka streams - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15026) Implement min-cost flow balancing tasks for same subtopology - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15023) Get rack information for source topic partitions for a task - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15025) Implement min-cost flow without balancing tasks for same subtopology - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15024) Add cost function for task/client - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15054) Add configs and logic to decide if rack aware assignment should be enabled - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15027) Implement rack aware assignment for standby tasks - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:17:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15026) Implement min-cost flow balancing tasks for same subtopology - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/06 16:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-14589 ConsumerGroupCommand rewritten in java [kafka] - posted by "tledkov (via GitHub)" <gi...@apache.org> on 2023/12/06 16:30:55 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15910) New group coordinator needs to generate snapshots while loading - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/06 16:39:00 UTC, 0 replies.
- [PR] KAFKA-15978: Update member information on HB response [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/06 16:58:18 UTC, 18 replies.
- Re: [PR] KAFKA-13788: Use AdminClient.incrementalAlterConfigs in ConfigCommand [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/06 17:02:06 UTC, 1 replies.
- [PR] MINOR: Support to update Async Consumer group member label (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2023/12/06 17:43:26 UTC, 7 replies.
- Re: [PR] KAFKA-15764: Missing Tests for Transactions [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/06 17:46:26 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer") - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/06 17:49:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15871) Implement kafka-client-metrics.sh tool - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2023/12/06 18:11:00 UTC, 0 replies.
- Re: [PR] KAFKA-15816: Fix leaked sockets in mirror tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/06 18:43:32 UTC, 1 replies.
- [jira] [Created] (KAFKA-15980) Add KIP-1001 CurrentControllerId metric - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/06 19:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15979) Add KIP-1001 CurrentControllerId metric - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/06 19:05:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15877) Support change of temporality in Java client - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/06 19:10:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15877) Support change of temporality in Java client - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/06 19:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15684) Add support to describe all subscriptions through utility - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2023/12/06 19:11:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15972) Add support to exclude labels in client telemetry - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2023/12/06 19:14:00 UTC, 0 replies.
- [PR] KAFKA-15347: fix unit test [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2023/12/06 20:36:41 UTC, 2 replies.
- [jira] [Created] (KAFKA-15981) only record GenericGroup state metrics once per group during load - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2023/12/06 21:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15982) Move GenericGroup state metrics to `GroupCoordinatorMetricsShard` - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2023/12/06 21:38:00 UTC, 0 replies.
- [PR] KAFKA-15215: docs for KIP-954 [kafka] - posted by "agavra (via GitHub)" <gi...@apache.org> on 2023/12/06 23:47:30 UTC, 3 replies.
- Re: [PR] KAFKA-15696: Refactor closing consumer [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/06 23:50:19 UTC, 54 replies.
- [jira] [Created] (KAFKA-15983) Kafka-acls should return authorization already done if repeat work is issued - posted by "Chen He (Jira)" <ji...@apache.org> on 2023/12/07 00:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15983) Kafka-acls should return authorization already done if repeat work is issued - posted by "Chen He (Jira)" <ji...@apache.org> on 2023/12/07 00:44:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15983) Kafka-acls should return authorization already done if repeating work is issued - posted by "Chen He (Jira)" <ji...@apache.org> on 2023/12/07 00:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15984) Client disconnections can cause hanging transactions on __consumer_offsets - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/07 00:52:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/07 00:52:00 UTC, 0 replies.
- [PR] MINOR: remove the use of ConsumerTestBuilder from MembershipManagerImplTest [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2023/12/07 01:14:42 UTC, 2 replies.
- [jira] [Commented] (KAFKA-12670) KRaft support for unclean.leader.election.enable - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/07 01:24:00 UTC, 1 replies.
- Re: [PR] KAFKA-15178: Improve ConsumerCoordinator.poll perf [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/07 03:33:32 UTC, 0 replies.
- Re: [PR] KAFKA-13109: SourceTask#poll not enforcing retries in case of RetriableException [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/07 03:33:47 UTC, 0 replies.
- Re: [PR] KAFKA-15980: add KIP-1001 CurrentControllerId metric [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2023/12/07 05:03:35 UTC, 0 replies.
- [PR] MINOR: Add documentation for docker image github actions [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/07 08:04:11 UTC, 1 replies.
- [PR] MINOR: log error when initialLoadFuture is not done in authorizer [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/07 09:24:48 UTC, 2 replies.
- [PR] MINOR: Bug fixes for AssignmentsManager [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/07 09:43:26 UTC, 5 replies.
- [PR] Bugfix: Prevent java.lang.UnsupportedOperationException. [kafka] - posted by "jamespfaulkner (via GitHub)" <gi...@apache.org> on 2023/12/07 09:52:44 UTC, 1 replies.
- [jira] [Created] (KAFKA-15985) Mirrormaker 2 offset sync is incomplete - posted by "Philipp Dallig (Jira)" <ji...@apache.org> on 2023/12/07 10:41:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15985) Mirrormaker 2 offset sync is incomplete - posted by "Philipp Dallig (Jira)" <ji...@apache.org> on 2023/12/07 10:42:00 UTC, 2 replies.
- [PR] MINOR: Remove `SubscribedTopicRegex` field from `ConsumerGroupHeartbeatRequest` [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/07 11:01:14 UTC, 7 replies.
- [PR] KAFKA-15347: implement lazy deserialization for segment [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2023/12/07 11:22:24 UTC, 28 replies.
- Re: [PR] KAFKA-10706; Ensure leader epoch cache is cleaned after truncation to end offset [kafka] - posted by "hudeqi (via GitHub)" <gi...@apache.org> on 2023/12/07 11:47:20 UTC, 0 replies.
- [PR] Update upgrade-guide.html for KIP-960 and KIP-968 [kafka] - posted by "aliehsaeedii (via GitHub)" <gi...@apache.org> on 2023/12/07 11:56:49 UTC, 9 replies.
- [PR] MINOR: Avoid leaking threads in DelegationTokenEndToEndAuthorizationWithOwnerTest.testDescribeTokenForOtherUserFails [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/07 12:51:47 UTC, 6 replies.
- [PR] MINOR: Fix leak thread in DeleteTopicTest.testIncreasePartitionCountDuringDeleteTopic [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/07 13:32:32 UTC, 1 replies.
- [PR] Revert "MINOR: Add junit properties to display parameterized test names (#14687)" [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/07 13:40:12 UTC, 5 replies.
- [jira] [Commented] (KAFKA-15985) Mirrormaker 2 offset sync is incomplete - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/07 14:52:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-14132) Remaining PowerMock to Mockito tests - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/07 15:02:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-15985) Mirrormaker 2 offset sync is incomplete - posted by "Philipp Dallig (Jira)" <ji...@apache.org> on 2023/12/07 15:34:00 UTC, 0 replies.
- [PR] KAFKA-15775: New consumer listTopics and partitionsFor [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/07 16:13:15 UTC, 6 replies.
- [jira] [Created] (KAFKA-15986) New consumer group protocol integration test failures - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/07 16:24:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15987) Refactor ReplicaManager code - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/07 16:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15987) Refactor ReplicaManager code - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/07 16:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15942) Implement ConsumerInterceptor - posted by "johndoe (Jira)" <ji...@apache.org> on 2023/12/07 16:37:00 UTC, 1 replies.
- [PR] KAFKA-15942: Implement ConsumerInterceptor [kafka] - posted by "Joker-5 (via GitHub)" <gi...@apache.org> on 2023/12/07 17:00:11 UTC, 12 replies.
- [PR] KAFKA-15986: Fix integration test failures [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2023/12/07 17:08:51 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15858) Broker stays fenced until all assignments are correct - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2023/12/07 17:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15844) Broker doesn't re-register after losing ZK session - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2023/12/07 18:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15846) Review consumer leave group request best effort - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/07 18:53:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-15988) Kafka Connect OffsetsApiIntegrationTest takes too long - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/07 19:54:00 UTC, 0 replies.
- [PR] Rackaware assignment tests fix [kafka] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2023/12/07 19:56:03 UTC, 0 replies.
- [PR] KAFKA-15988: Reuse embedded clusters across test cases in Connect OffsetsApiIntegrationTest suite [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2023/12/07 20:47:03 UTC, 20 replies.
- [jira] [Assigned] (KAFKA-15906) Emit offset syncs more often than offset.lag.max for low-throughput/finite partitions - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/07 21:18:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/07 21:19:00 UTC, 0 replies.
- [PR] KAFKA-15906: Emit latest MM2 offset syncs every offset.flush.interval.ms [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/07 22:13:14 UTC, 5 replies.
- [PR] Minor: JBOD migration [kafka] - posted by "pprovenzano (via GitHub)" <gi...@apache.org> on 2023/12/07 22:15:42 UTC, 4 replies.
- [jira] [Updated] (KAFKA-15981) only record GenericGroup state metrics once per group during load - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2023/12/07 22:18:00 UTC, 1 replies.
- Re: [PR] MINOR: Improve KRaftMigrationZkWriter test coverage [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/08 03:33:20 UTC, 0 replies.
- [PR] Native docker image kafka 15444 [kafka] - posted by "kagarwal06 (via GitHub)" <gi...@apache.org> on 2023/12/08 04:00:28 UTC, 0 replies.
- [PR] KAFKA-15714: KRaft support in DynamicNumNetworkThreadsTest [kafka] - posted by "phong260702 (via GitHub)" <gi...@apache.org> on 2023/12/08 04:33:11 UTC, 3 replies.
- [PR] KAFKA-15911: making sure the follower is making progress [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/08 06:56:33 UTC, 1 replies.
- [PR] MINOR: Use regctl in docker image promote workflow [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/08 07:11:40 UTC, 2 replies.
- [PR] MINOR: Fix raft-metrics descriptions at docs/ops.html [kafka] - posted by "tkuramoto33 (via GitHub)" <gi...@apache.org> on 2023/12/08 07:43:30 UTC, 0 replies.
- [PR] MINOR: Use docker buildx to promote docker image [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/08 07:57:59 UTC, 1 replies.
- [jira] [Created] (KAFKA-15989) Upgrade existing generic group to consumer group - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2023/12/08 08:32:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15718) KRaft support in UncleanLeaderElectionTest - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2023/12/08 09:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15718) KRaft support in UncleanLeaderElectionTest - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2023/12/08 09:50:00 UTC, 0 replies.
- [PR] MINOR: fix leak in `GroupEndToEndAuthorizationTest` [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/08 09:51:23 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15986) New consumer group protocol integration test failures - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/08 10:09:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/08 10:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15990) Add additional parameter which allows parameter remote.enabled and its relatives to be wiped if server tiering is disabled - posted by "Viktor Nikitash (Jira)" <ji...@apache.org> on 2023/12/08 11:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15990) Add additional parameter which allows parameter remote.enabled and its relatives to be wiped if server tiering is disabled - posted by "Viktor Nikitash (Jira)" <ji...@apache.org> on 2023/12/08 11:24:00 UTC, 3 replies.
- [PR] KAFKA-15361: Migrating brokers register with dirs [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/08 12:14:47 UTC, 6 replies.
- [jira] [Resolved] (KAFKA-15979) Add KIP-1001 CurrentControllerId metric - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/08 12:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15989) Upgrade existing generic group to consumer group - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/08 12:46:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15989) Upgrade existing generic group to consumer group - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/08 12:47:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14516) Implement static membeship - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/08 13:00:00 UTC, 0 replies.
- Re: [PR] MINOR: Add retry for CI [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/08 13:38:50 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15980) Add KIP-1001 CurrentControllerId metric - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/08 13:40:00 UTC, 1 replies.
- [PR] KAFKA-15366: Modify LogDirFaulureTest for KRaft [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2023/12/08 13:46:47 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15985) Mirrormaker 2 offset sync is incomplete - posted by "Philipp Dallig (Jira)" <ji...@apache.org> on 2023/12/08 15:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15987) Refactor ReplicaManager code for transaction verification - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/08 17:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15208) Upgrade Jackson dependencies to version 2.16.0 - posted by "Said BOUDJELDA (Jira)" <ji...@apache.org> on 2023/12/08 17:33:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15208) Upgrade Jackson dependencies to version 2.15.6 - posted by "Said BOUDJELDA (Jira)" <ji...@apache.org> on 2023/12/08 17:33:00 UTC, 1 replies.
- Re: [PR] MINOR: allow JBOD during ZK migration [kafka] - posted by "pprovenzano (via GitHub)" <gi...@apache.org> on 2023/12/08 19:25:50 UTC, 1 replies.
- Re: [PR] KAFKA-13328, KAFKA-13329 (1): Add preflight validations for key, value, and header converter classes [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2023/12/08 20:00:12 UTC, 1 replies.
- Re: [PR] KAFKA-15366: Modify LogDirFailureTest for KRaft [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/08 20:05:48 UTC, 21 replies.
- [jira] [Commented] (KAFKA-10457) JsonConverter.toConnectData trims BigInteger to Long for schema-less case - posted by "Waleed Fateem (Jira)" <ji...@apache.org> on 2023/12/08 20:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-15456: Commit/Fetch error handling improvements and V9 support [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2023/12/08 22:15:37 UTC, 51 replies.
- Re: [PR] KAFKA-15816: Fix leaked sockets in core tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/08 22:53:20 UTC, 0 replies.
- [jira] [Created] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/08 23:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14748) Relax non-null FK left-join requirement - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2023/12/09 08:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-12317) Relax non-null key requirement for left/outer KStream joins - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2023/12/09 08:21:00 UTC, 0 replies.
- [PR] KAFKA-15556 [WIP]: Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect [kafka] - posted by "Phuc-Hong-Tran (via GitHub)" <gi...@apache.org> on 2023/12/09 12:26:24 UTC, 3 replies.
- [PR] KAFKA-15556: Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect [kafka] - posted by "Phuc-Hong-Tran (via GitHub)" <gi...@apache.org> on 2023/12/09 14:13:09 UTC, 16 replies.
- Re: [PR] MINOR: Upgrade maven Artifact version to 3.9.4 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/10 03:33:15 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15714) KRaft support in DynamicNumNetworkThreadsTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/10 12:35:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15714) KRaft support in DynamicNumNetworkThreadsTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/10 12:35:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-10457) JsonConverter.toConnectData trims BigInteger to Long for schema-less case - posted by "Sudesh Wasnik (Jira)" <ji...@apache.org> on 2023/12/10 18:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-15042: Improve TAGGED_FIELDS protocol documentation [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/11 03:33:18 UTC, 0 replies.
- Re: [PR] KAFKA-14995: Automate asf.yaml collaborators refresh [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/11 03:33:32 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14237) Kafka TLS Doesn't Present Intermediary Certificates when using PEM - posted by "Matthew de Detrich (Jira)" <ji...@apache.org> on 2023/12/11 06:24:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-14572) Migrate EmbeddedKafkaCluster used by Streams integration tests from EmbeddedZookeeper to KRaft - posted by "Matthew de Detrich (Jira)" <ji...@apache.org> on 2023/12/11 06:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14572) Migrate EmbeddedKafkaCluster used by Streams integration tests from EmbeddedZookeeper to KRaft - posted by "Matthew de Detrich (Jira)" <ji...@apache.org> on 2023/12/11 06:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/11 07:55:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/11 07:57:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15978) New consumer sends OffsetCommit with empty member ID - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/11 07:58:00 UTC, 0 replies.
- [PR] KAFKA-15817: Avoid reconnecting to the same IP address (#14813) [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/11 08:12:27 UTC, 0 replies.
- [PR] KAFKA-15237: Enforcing write timeouts when writing to the log [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2023/12/11 08:35:30 UTC, 1 replies.
- [jira] [Updated] (KAFKA-13922) Unable to generate coverage reports for the whole project - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/11 08:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15992) Make MM2 heartbeats topic name configurable - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/11 09:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15992) Make MM2 heartbeats topic name configurable - posted by "Viktor Somogyi-Vass (Jira)" <ji...@apache.org> on 2023/12/11 09:20:00 UTC, 0 replies.
- Re: [PR] MINOR: Fix rack-aware assignment tests [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/11 09:38:59 UTC, 0 replies.
- Re: [PR] KAFKA-15161: Fix InvalidReplicationFactorException at connect startup [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2023/12/11 10:41:51 UTC, 0 replies.
- [PR] KAFKA-15363: Run completion handlers for duped AssignmentEvent [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/11 10:49:31 UTC, 3 replies.
- Re: [PR] KAFKA-15870: Move new group coordinator metrics from Yammer to Metrics [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/11 11:07:21 UTC, 16 replies.
- [jira] [Assigned] (KAFKA-15992) Make MM2 heartbeats topic name configurable - posted by "Bertalan Kondrat (Jira)" <ji...@apache.org> on 2023/12/11 11:16:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15497) Refactor build.gradle and split each module configuration on the module itself - posted by "Bertalan Kondrat (Jira)" <ji...@apache.org> on 2023/12/11 11:17:00 UTC, 0 replies.
- Re: [PR] KAFKA-15237: Implement write operation timeout [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/11 13:08:46 UTC, 20 replies.
- Re: [PR] KAFKA-15913: Migrate async consumer tests to mocks [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/11 13:21:27 UTC, 9 replies.
- Re: [PR] KAFKA-15208: Upgrade Jackson dependencies to version 2.16.0 [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/11 14:48:51 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-15922) Add MetadataVersion for JBOD - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2023/12/11 15:16:00 UTC, 0 replies.
- [PR] KAFKA-15922: Bump MetadataVersion to support JBOD with KRaft [kafka] - posted by "pprovenzano (via GitHub)" <gi...@apache.org> on 2023/12/11 15:39:28 UTC, 26 replies.
- Re: [PR] KAFKA-15471: Allow independently stop KRaft controllers or brokers [kafka] - posted by "rondagostino (via GitHub)" <gi...@apache.org> on 2023/12/11 15:47:17 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-15893) Bump MetadataVersion for directory assignments - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2023/12/11 16:14:00 UTC, 0 replies.
- Re: [PR] KAFKA-7839 Add quotes to CLASSPATH on Java start [kafka] - posted by "rwunderer (via GitHub)" <gi...@apache.org> on 2023/12/11 16:23:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15950) Serialize broker heartbeat requests - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2023/12/11 17:16:00 UTC, 4 replies.
- Re: [PR] KAFKA-15991: Fix flaky test testGroupIdNotNullAndValid [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/11 17:47:32 UTC, 3 replies.
- Re: [PR] KAFKA-15417 flip joinSpuriousLookBackTimeMs and emit non-joined items [kafka] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2023/12/11 18:40:57 UTC, 0 replies.
- Re: [PR] KAFKA-15143: Adding in MockFixedKeyProcessorContext and Test [kafka] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2023/12/11 18:43:30 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15574) Update states and transitions for membership manager state machine - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/11 19:08:00 UTC, 0 replies.
- [PR] KAFKA-14505; [3/N] Wire WriteTxnMarkers API [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/11 19:30:30 UTC, 66 replies.
- [jira] [Created] (KAFKA-15993) Enable integration tests that relies on rebalance listener - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/11 20:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15993) Enable integration tests that relies on rebalance listener - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/11 20:38:00 UTC, 6 replies.
- [PR] MINOR: add entity type to topic names in ConsumerGroupDescribeResponse.json [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2023/12/11 20:38:33 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15563) Provide informative error messages when Connect REST requests time out - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/11 21:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-15826: Close consumer when sink task is cancelled [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/11 22:22:06 UTC, 0 replies.
- [PR] MINOR: Allow Block.resetBlockLatch to release blocked operation for end-of-test cleanup [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/11 22:53:08 UTC, 4 replies.
- [jira] [Updated] (KAFKA-15981) only record Group state metrics once per group during load - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2023/12/11 23:34:00 UTC, 0 replies.
- Re: [PR] KAFKA-15373: fix exception thrown in Admin#describeTopics for unknown ID [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/12 00:19:59 UTC, 6 replies.
- [jira] [Updated] (KAFKA-15981) update Group size only when groups size changes - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2023/12/12 00:33:00 UTC, 1 replies.
- [PR] KAFKA-15981: update Group size only when groups size changes [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2023/12/12 00:33:08 UTC, 4 replies.
- [jira] [Updated] (KAFKA-10404) Flaky Test kafka.api.SaslSslConsumerTest.testCoordinatorFailover - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/12 04:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7605) Flaky Test `SaslMultiMechanismConsumerTest.testCoordinatorFailover` - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/12 04:27:00 UTC, 0 replies.
- Re: [PR] MINOR: edit enableCleaner description [kafka] - posted by "laststem (via GitHub)" <gi...@apache.org> on 2023/12/12 05:42:05 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15879) Add documentation and examples for the Docker image - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/12 06:02:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15880) Add github actions workflow for promoting RC docker image - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/12 06:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15903) Add github actions workflow for building and pushing RC Docker Image - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/12 06:04:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15881) Make changes in Release Process Wiki and Release Process - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/12 06:05:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-15994) Add complex example compose file - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/12 06:34:00 UTC, 0 replies.
- [PR] MINOR: Fix typos in docker/example/README.md [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/12 07:15:37 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/12 07:39:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-15995) Mechanism for plugins and connectors to register metrics - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/12 08:48:00 UTC, 0 replies.
- [PR] KAFKA-15881: Update Release Process for Docker images documentation [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/12 10:22:07 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15963) Flaky test: testBrokerHeartbeatDuringMigration [3] 3.6-IV0 – org.apache.kafka.controller.QuorumControllerTest - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2023/12/12 11:03:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15996) json serializer too slow - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2023/12/12 11:38:00 UTC, 0 replies.
- [PR] MINOR: Rename and update test files for docker image [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/12 13:31:58 UTC, 1 replies.
- [PR] KAFKA-15996: Improve JsonConverter performance [kafka] - posted by "mfvitale (via GitHub)" <gi...@apache.org> on 2023/12/12 13:35:43 UTC, 20 replies.
- [PR] MINOR: Bump trunk to 3.8.0-SNAPSHOT [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2023/12/12 13:49:05 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15992) Make MM2 heartbeats topic name configurable - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/12 14:20:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15190) Allow configuring a streams process ID - posted by "Joe Wreschnig (Jira)" <ji...@apache.org> on 2023/12/12 14:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15996) json serializer too slow - posted by "WangMinChao (Jira)" <ji...@apache.org> on 2023/12/12 14:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15090) Source tasks are no longer stopped on a separate thread - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2023/12/12 14:52:00 UTC, 1 replies.
- [PR] MINOR: Few cleanups to JaasContext/Utils classes [kafka] - posted by "q-ryanamiri (via GitHub)" <gi...@apache.org> on 2023/12/12 16:35:08 UTC, 0 replies.
- [jira] [Created] (KAFKA-15997) Ensure fairness in the uniform assignor - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2023/12/12 17:20:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15997) Ensure fairness in the uniform assignor - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/12 17:23:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/12 17:27:00 UTC, 0 replies.
- Re: [PR] MINOR: Stop leaking threads in BlockingConnectorTest [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/12 19:13:41 UTC, 9 replies.
- [PR] KAFKA-14822: Allow restricting File and Directory ConfigProviders to specific paths [kafka] - posted by "tinaselenge (via GitHub)" <gi...@apache.org> on 2023/12/12 19:13:59 UTC, 3 replies.
- [jira] [Created] (KAFKA-15998) EAGER rebalance onPartitionsAssigned() called with no previous onPartitionsLost() nor onPartitionsRevoked() - posted by "Jonathan Haapala (Jira)" <ji...@apache.org> on 2023/12/12 19:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15998) EAGER rebalance onPartitionsAssigned() called with no previous onPartitionsLost() nor onPartitionsRevoked() - posted by "Jonathan Haapala (Jira)" <ji...@apache.org> on 2023/12/12 19:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15913) Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/12 20:02:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15913) Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/12 20:02:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/12 20:04:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16001) Migrate ConsumerNetworkThreadTestBuilder away from ConsumerTestBuilder - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/12 20:05:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16000) Migrate MembershipManagerImpl away from ConsumerTestBuilder - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/12 20:05:00 UTC, 0 replies.
- [PR] KAFKA-15471 [MINOR]: Fix backward-compatibility bug [kafka] - posted by "hni61223 (via GitHub)" <gi...@apache.org> on 2023/12/12 20:31:43 UTC, 9 replies.
- [PR] MINOR: Give FETCH request own MetadataVersion [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/12 23:13:38 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15372) MM2 rolling restart can drop configuration changes silently - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/12 23:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15372) MM2 rolling restart can drop configuration changes silently - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/12 23:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15111) Correction kafka examples - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/12 23:40:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15111) Correction kafka examples - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/12 23:40:00 UTC, 0 replies.
- [PR] KAFKA-15364: Replay BrokerRegistrationChangeRecord.logDirs [kafka] - posted by "soarez (via GitHub)" <gi...@apache.org> on 2023/12/13 00:01:05 UTC, 8 replies.
- [PR] MINOR: docs for rack aware assignment [kafka] - posted by "lihaosky (via GitHub)" <gi...@apache.org> on 2023/12/13 00:27:04 UTC, 2 replies.
- Re: [PR] Minor : Increase Config change throwable log info to error [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/13 03:33:14 UTC, 0 replies.
- Re: [PR] MINOR: Upgrade jqwik to version 1.8.0 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/13 03:33:15 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions() - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/13 04:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15881) Make changes in Release Process Wiki and Release Process - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/13 07:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15981) update Group size only when groups size changes - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/13 08:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individually but not when is run as part of the IT - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/13 08:34:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-16002) Implement RemoteCopyLagSegments, RemoteDeleteLagBytes and RemoteDeleteLagSegments - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2023/12/13 10:00:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16003) The znode /config/topics is not updated during KRaft migration in "dual-write" mode - posted by "Paolo Patierno (Jira)" <ji...@apache.org> on 2023/12/13 11:00:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16003) The znode /config/topics is not updated during KRaft migration in "dual-write" mode - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/13 11:42:00 UTC, 0 replies.
- Re: [PR] KAFKA-15158: Add metrics for RemoteRequestsPerSec [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/13 11:45:35 UTC, 13 replies.
- [PR] KAFKA-15942: Implement ConsumerInterceptors in the async consumer [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/13 12:41:49 UTC, 2 replies.
- [PR] MINOR: transform new coordinator error before returning to client [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2023/12/13 13:41:15 UTC, 6 replies.
- [jira] [Created] (KAFKA-16004) Review new consumer inflight offset commit logic - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/13 14:35:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16005) ZooKeeper to KRaft migration rollback missing disabling controller and migration configuration on brokers - posted by "Paolo Patierno (Jira)" <ji...@apache.org> on 2023/12/13 14:37:00 UTC, 0 replies.
- [PR] MINOR Minor Cleanup KRaft code [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2023/12/13 15:36:07 UTC, 18 replies.
- [PR] MINOR: Client state machine fix for ignoring new assignments when leaving [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2023/12/13 15:45:16 UTC, 6 replies.
- [jira] [Closed] (KAFKA-15868) KIP-951 - Leader discovery optimisations for the client - posted by "Mayank Shekhar Narula (Jira)" <ji...@apache.org> on 2023/12/13 18:02:00 UTC, 0 replies.
- [PR] MINOR: Client state machine fix for fencing while preparing to leave [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2023/12/13 18:49:15 UTC, 3 replies.
- Re: [PR] MINOR: Give FETCH request own MetadataVersion for KIP-951 [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/13 18:50:21 UTC, 1 replies.
- [PR] KAFKA-16002: Implement RemoteCopyLagSegments, RemoteDeleteLagBytes and RemoteDeleteLagSegments [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2023/12/13 18:59:09 UTC, 28 replies.
- [PR] MINOR: Fix thread leak in AuthorizerIntegrationTest [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/13 19:25:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15237) Implement write operation timeout - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/13 19:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16003) The znode /config/topics is not updated during KRaft migration in "dual-write" mode - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/13 20:12:00 UTC, 8 replies.
- [jira] [Created] (KAFKA-16006) mTLS authentication works for kafka-topic.sh but fails for kafka-metadata-quorum.sh - posted by "10011 (Jira)" <ji...@apache.org> on 2023/12/13 21:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16006) mTLS authentication works for kafka-topic.sh but fails for kafka-metadata-quorum.sh - posted by "10011 (Jira)" <ji...@apache.org> on 2023/12/13 21:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16007) ZK migrations can be slow for large clusters - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/13 22:05:00 UTC, 0 replies.
- [PR] KAFKA-16007 Re-batch records during the migration [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2023/12/13 22:19:45 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15835) Group commit/callbacks triggering logic - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/13 23:03:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:15:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:22:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:28:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:46:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/13 23:46:00 UTC, 0 replies.
- [PR] MINOR: Prototype: Measure CI slowness [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2023/12/14 00:47:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15883) Implement RemoteCopyLagBytes - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/14 01:22:00 UTC, 0 replies.
- [PR] [DO NOT MERGE] KAFKA-14419: limit time spent processing during ongoing rebalance and delay followup rebalance trigger [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2023/12/14 01:40:30 UTC, 0 replies.
- [jira] [Created] (KAFKA-16012) Incomplete range assignment in consumer - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2023/12/14 01:43:00 UTC, 0 replies.
- Re: [PR] KAFKA-15711: KRaft support in LogRecoveryTest [kafka] - posted by "linzihao1999 (via GitHub)" <gi...@apache.org> on 2023/12/14 03:45:09 UTC, 0 replies.
- Re: [PR] MINOR: Fix descriptions of raft-metrics in docs/ops.html [kafka] - posted by "tkuramoto33 (via GitHub)" <gi...@apache.org> on 2023/12/14 04:40:51 UTC, 0 replies.
- [jira] [Commented] (KAFKA-10409) Refactor Kafka Streams RocksDb iterators - posted by "Dhawal Kapil (Jira)" <ji...@apache.org> on 2023/12/14 05:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15158) Add metrics for RemoteRequestsPerSec - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/14 06:06:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15158) Add metrics for RemoteDeleteRequestsPerSec, RemoteDeleteErrorsPerSec, BuildRemoteLogAuxStateRequestsPerSec, BuildRemoteLogAuxStateErrorsPerSec - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/14 06:07:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16013) Implement ExpiresPerSec metric - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/14 06:10:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16014) Implement RemoteLogSizeComputationTime, RemoteLogSizeBytes, RemoteLogMetadataCount - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/14 06:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15147) Measure pending and outstanding Remote Segment operations - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/14 06:12:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16013) Implement ExpiresPerSec metric - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/14 07:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15147) Measure pending and outstanding Remote Segment operations - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/14 08:45:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-15406) Add the ForwardingManager metrics from KIP-938 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/14 08:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15406) Add the ForwardingManager metrics from KIP-938 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/14 08:47:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15448) Streams StandbyTaskUpdateListener - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/14 08:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15781) Change ProducerConfig(props, doLog) constructor to protected - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/14 08:52:00 UTC, 0 replies.
- [PR] MINOR: Update documentation.html with the 3.7 release [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2023/12/14 09:01:41 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-16005) ZooKeeper to KRaft migration rollback missing disabling controller and migration configuration on brokers - posted by "Paolo Patierno (Jira)" <ji...@apache.org> on 2023/12/14 09:21:00 UTC, 0 replies.
- [PR] KAFKA-16005: ZooKeeper to KRaft migration rollback missing disabling controller and migration configuration on brokers [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2023/12/14 09:23:27 UTC, 7 replies.
- [PR] KAFKA-15882: Add nightly docker image scan job [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/14 09:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16013) Implement ExpiresPerSec metric - posted by "Nikhil Ramakrishnan (Jira)" <ji...@apache.org> on 2023/12/14 10:45:00 UTC, 3 replies.
- [PR] KAFKA-16013: Add metric for expiration rate of delayed remote fetch [kafka] - posted by "nikramakrishnan (via GitHub)" <gi...@apache.org> on 2023/12/14 11:38:20 UTC, 14 replies.
- [PR] KAFKA-16013: impelement ExpiresPerSec for remote fetch [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/14 12:14:27 UTC, 4 replies.
- [jira] [Commented] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage. - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/14 13:32:00 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-16005) ZooKeeper to KRaft migration rollback missing disabling controller and migration configuration on brokers - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/14 14:03:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15147) Measure pending and outstanding Remote Segment operations - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2023/12/14 15:55:00 UTC, 1 replies.
- [PR] Test branch [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/14 17:39:32 UTC, 7 replies.
- [PR] MINOR: log new coordinator load schedule time [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2023/12/14 18:38:45 UTC, 0 replies.
- [PR] test [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/14 18:43:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15784) Ensure atomicity of in memory update and write when transactionally committing offsets - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/14 19:07:00 UTC, 0 replies.
- Re: [PR] MINOR: Minor update patch versions [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/14 19:14:56 UTC, 3 replies.
- Re: [PR] MINOR; Fix KRaft metadata version system tests [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/14 19:20:18 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16003) The znode /config/topics is not updated during KRaft migration in "dual-write" mode - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/14 19:51:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16012) Incomplete range assignment in consumer - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2023/12/14 19:51:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16012) Incomplete range assignment in consumer - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/14 21:07:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15893) Bump MetadataVersion for directory assignments - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2023/12/14 21:25:00 UTC, 0 replies.
- [PR] Fix so that a partition is retained, if the another parititon on same… [kafka] - posted by "msn-tldr (via GitHub)" <gi...@apache.org> on 2023/12/14 23:37:43 UTC, 0 replies.
- Re: [PR] KAFKA-16007 Merge batch records during ZK migration [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2023/12/15 01:39:56 UTC, 14 replies.
- [jira] [Assigned] (KAFKA-14508) Add ConsumerGroupInstallAssignment API - posted by "Alexander Aghili (Jira)" <ji...@apache.org> on 2023/12/15 05:48:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15242) FixedKeyProcessor testing is unusable - posted by "Alexander Aghili (Jira)" <ji...@apache.org> on 2023/12/15 05:55:00 UTC, 0 replies.
- [PR] KAFKA-16014: add RemoteLogSizeComputationTime metric [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/15 09:41:11 UTC, 5 replies.
- [jira] [Created] (KAFKA-16015) kafka-leader-election timeout values always overwritten b default values - posted by "Sergio Troiano (Jira)" <ji...@apache.org> on 2023/12/15 09:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16015) kafka-leader-election timeout values always overwritten b default values - posted by "Sergio Troiano (Jira)" <ji...@apache.org> on 2023/12/15 09:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16015) kafka-leader-election timeout values always overwritten b default values - posted by "Sergio Troiano (Jira)" <ji...@apache.org> on 2023/12/15 09:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16015) kafka-leader-election timeout values always overwritten by default values - posted by "Sergio Troiano (Jira)" <ji...@apache.org> on 2023/12/15 09:50:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-16016) Migrate utility scripts to kafka codebase - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2023/12/15 10:25:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15971) Re-enable consumer integration tests for new consumer - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/15 13:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16017) Checkpointed offset is incorrect when task is revived and restoring - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/15 14:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16017) Checkpointed offset is incorrect when task is revived and restoring - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/15 14:13:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16017) Checkpointed offset is incorrect when task is revived and restoring - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/15 14:43:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16015) kafka-leader-election timeout values always overwritten by default values - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2023/12/15 15:06:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16018) KafkaStreams can go into a zombie state if UncaughtExceptionHandler is specified via the deprecated method - posted by "Tommy Becker (Jira)" <ji...@apache.org> on 2023/12/15 17:48:00 UTC, 0 replies.
- [PR] KAFKA-16003: Always create the /config/topics ZNode even for topics w… [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/15 18:16:08 UTC, 0 replies.
- [jira] [Created] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invokes and verify the consumer callback - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/15 19:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invokes and verify the consumer callback - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/15 19:14:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task - posted by "Sabit (Jira)" <ji...@apache.org> on 2023/12/15 19:15:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16020) Time#waitForFuture should tolerate nanosecond overflow - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/15 19:58:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15471) Allow independently stop KRaft controllers or brokers - posted by "Ron Dagostino (Jira)" <ji...@apache.org> on 2023/12/15 20:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15471) Allow independently stop KRaft controllers or brokers - posted by "Ron Dagostino (Jira)" <ji...@apache.org> on 2023/12/15 20:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15358) QueuedReplicaToDirAssignments metric - posted by "Ron Dagostino (Jira)" <ji...@apache.org> on 2023/12/15 20:24:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15365) Broker-side replica management changes - posted by "Ron Dagostino (Jira)" <ji...@apache.org> on 2023/12/15 20:25:00 UTC, 0 replies.
- [PR] KAFKA-16012: Ensure new leader information merged correctly with the current metadata [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/15 22:11:02 UTC, 44 replies.
- [jira] [Created] (KAFKA-16021) Eagerly load Charset for StringSerializer/StringDeserializer - posted by "Stig Rohde Døssing (Jira)" <ji...@apache.org> on 2023/12/15 23:32:00 UTC, 0 replies.
- [PR] KAFKA-16021: Eagerly look up StringSerializer encoding during configure [kafka] - posted by "srdo (via GitHub)" <gi...@apache.org> on 2023/12/15 23:39:52 UTC, 7 replies.
- [jira] [Created] (KAFKA-16022) AsyncKafkaConsumer sometimes complains "No current assignment for partition {}" - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/16 05:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16022) AsyncKafkaConsumer sometimes complains "No current assignment for partition {}" - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/16 05:10:00 UTC, 3 replies.
- [jira] [Created] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/16 05:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/16 05:19:00 UTC, 4 replies.
- [PR] KAFKA-16023: Disable flaky tests [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/16 05:36:03 UTC, 3 replies.
- [PR] KAFKA-16014: add RemoteLogMetadataCount metric [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/16 06:36:18 UTC, 14 replies.
- [PR] KAFKA-13949: /connectors endpoint supports listing task-configs and a… [kafka] - posted by "sudeshwasnik (via GitHub)" <gi...@apache.org> on 2023/12/16 13:23:09 UTC, 0 replies.
- [PR] KAFKA-15747: KRaft support in DynamicConnectionQuotaTest [kafka] - posted by "phong260702 (via GitHub)" <gi...@apache.org> on 2023/12/16 17:02:17 UTC, 0 replies.
- Re: [PR] [WIP] MINOR: Fix tests [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/17 03:33:19 UTC, 0 replies.
- [PR] Revert "KAFKA-15764: Missing Tests for Transactions (#14702)" [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/17 09:28:42 UTC, 4 replies.
- [PR] [KAFKA-16015] Fix custom timeouts overwritten by defaults [kafka] - posted by "sciclon2 (via GitHub)" <gi...@apache.org> on 2023/12/17 14:26:54 UTC, 10 replies.
- [PR] MINOR: Fix typo [kafka] - posted by "JoeCqupt (via GitHub)" <gi...@apache.org> on 2023/12/17 15:11:51 UTC, 2 replies.
- [PR] KAFKA-15874: Add metric and request log attribute for deprecated request api versions (KIP-896) [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2023/12/17 17:29:29 UTC, 6 replies.
- [jira] [Created] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/17 17:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/17 17:39:00 UTC, 5 replies.
- [PR] MINOR: Client state machine fix for transition to stable on initial empty assignment [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2023/12/17 19:30:39 UTC, 8 replies.
- Re: [PR] KAFKA-15270: Integration tests for new consumer [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2023/12/17 19:36:53 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "Sabit (Jira)" <ji...@apache.org> on 2023/12/18 00:09:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "Sabit (Jira)" <ji...@apache.org> on 2023/12/18 00:09:00 UTC, 0 replies.
- [PR] RecordHeaders supports the addAll method [kafka] - posted by "funky-eyes (via GitHub)" <gi...@apache.org> on 2023/12/18 01:45:37 UTC, 0 replies.
- [PR] Send Poll event to the background thread [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/18 05:47:33 UTC, 0 replies.
- [jira] [Created] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/18 08:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/18 08:00:00 UTC, 3 replies.
- Re: [PR] KAFKA-16026: Send Poll event to the background thread [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/18 08:06:26 UTC, 37 replies.
- [jira] [Created] (KAFKA-16027) Refactor MetadataTest#testUpdatePartitionLeadership - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/18 08:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16027) Refactor MetadataTest#testUpdatePartitionLeadership - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/18 08:17:00 UTC, 3 replies.
- [PR] Test refactor consumer close [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/18 08:47:45 UTC, 1 replies.
- [jira] [Created] (KAFKA-16028) AdminClient fails to describe consumer group - posted by "Ömer Şiar Baysal (Jira)" <ji...@apache.org> on 2023/12/18 09:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16028) AdminClient fails to describe consumer group - posted by "Ömer Şiar Baysal (Jira)" <ji...@apache.org> on 2023/12/18 09:49:00 UTC, 1 replies.
- Re: [PR] KAFKA-16013: Added integration test for ExpiresPerSec metric [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/18 10:19:19 UTC, 4 replies.
- [PR] MINOR: Fixed typo in quickstart documentation [kafka] - posted by "kumarlokesh (via GitHub)" <gi...@apache.org> on 2023/12/18 11:03:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16018) KafkaStreams can go into a zombie state if UncaughtExceptionHandler is specified via the deprecated method - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/18 11:20:00 UTC, 2 replies.
- Re: [PR] [MINOR] Refactor to only require one stopPartitions helper [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/18 11:35:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/18 11:40:00 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-15746) KRaft support in ControllerMutationQuotaTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2023/12/18 12:04:00 UTC, 0 replies.
- [PR] KAFKA-15746: KRaft support in ControllerMutationQuotaTest [kafka] - posted by "linzihao1999 (via GitHub)" <gi...@apache.org> on 2023/12/18 12:10:46 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15728) KRaft support in DescribeUserScramCredentialsRequestNotAuthorizedTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2023/12/18 12:50:00 UTC, 0 replies.
- [PR] Update upgrade guide for KIP 988 [kafka] - posted by "eduwercamacaro (via GitHub)" <gi...@apache.org> on 2023/12/18 12:53:59 UTC, 2 replies.
- [PR] MINOR:Fix hint for onPartitionReassignment [kafka] - posted by "hudeqi (via GitHub)" <gi...@apache.org> on 2023/12/18 13:06:46 UTC, 1 replies.
- [jira] [Created] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/18 15:09:00 UTC, 0 replies.
- [PR] MINOR: Use random cluster id for jsa file preparation [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/18 15:10:39 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15489) split brain in KRaft cluster - posted by "Roman Bondar (Jira)" <ji...@apache.org> on 2023/12/18 16:20:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16014) Implement RemoteLogSizeComputationTime, RemoteLogSizeBytes, RemoteLogMetadataCount - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2023/12/18 16:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/18 17:01:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16000) Migrate MembershipManagerImpl away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/18 17:06:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16030) new group coordinator should check if partition goes offline during load - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2023/12/18 19:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/18 20:09:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16030) new group coordinator should check if partition goes offline during load - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2023/12/18 20:30:00 UTC, 0 replies.
- [PR] KAFKA-16030: new group coordinator should check if partition goes offline during load [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2023/12/18 20:32:42 UTC, 3 replies.
- [jira] [Commented] (KAFKA-8359) Reconsider default for leader imbalance percentage - posted by "Leo Xuzhang Lin (Jira)" <ji...@apache.org> on 2023/12/18 20:53:00 UTC, 0 replies.
- [PR] KAFKA-16017: Checkpoint restored offsets instead of written offsets [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2023/12/18 21:13:43 UTC, 15 replies.
- [jira] [Updated] (KAFKA-15978) New consumer sends OffsetCommit with empty member ID - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:43:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15971) Re-enable consumer integration tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:43:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer") - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:44:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15986) New consumer group protocol integration test failures - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:44:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread? - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15942) Implement ConsumerInterceptor - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15866) Refactor OffsetFetchRequestState Error handling to be more consistent with OffsetCommitRequestState - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15174) Ensure the correct thread is executing the callbacks - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15946) AsyncKafkaConsumer should retry commits on the application thread instead of auto-retry - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15865) Ensure consumer.poll() execute autocommit callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15913) Migrate AsyncKafkaConsumerTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16000) Migrate MembershipManagerImpl away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15887) Autocommit during close consistently fails with exception in background thread - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15948) Refactor AsyncKafkaConsumer shutdown - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15803) Update last seen epoch during commit - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15872) Investigate autocommit retry logic - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15833) Restrict Consumer API to be used from one thread - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:47:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15839) Improve TopicIdPartition integration in consumer membershipManager - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15679) Client support for new consumer configs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:51:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15832) Trigger client reconciliation based on manager poll - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15967) Fix revocation in reconcilation logic - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:51:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15953) Refactor polling delays - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15847) Allow to resolve client metadata for specific topics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:53:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15842) Correct handling of KafkaConsumer.committed for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:54:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:54:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:54:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-16004) Review new consumer inflight offset commit logic - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15548) Send GroupConsumerHeartbeatRequest on Consumer.close() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:58:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15284) Implement ConsumerGroupProtocolVersionResolver to determine consumer group protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:58:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15696) Revoke partitions on Consumer.close() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:58:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15277) Design & implement support for internal Consumer delegates - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:58:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15534) Propagate client response time when timeout to the request handler - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:58:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15550) OffsetsForTimes validation for negative timestamps in new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:58:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15281) Implement the groupMetadata Consumer API - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:58:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15818) Implement max poll interval - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 02:59:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16000) Migrate MembershipManagerImplTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:08:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15691) Upgrade existing and add new system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:09:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15692) New integration tests to ensure full coverage - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:09:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15320) Document event queueing patterns - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:09:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15321) Document consumer group member state machine - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:10:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16031) Enabling testApplyDeltaShouldHandleReplicaAssignedToOnlineDirectory for tiered storage after supporting JBOD - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/19 03:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14246) Update threading model for Consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:13:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:13:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14675) Extract metadata-related tasks from Fetcher into MetadataFetcher - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15531) Ensure coordinator node is removed upon disconnection exception - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14252) Create background thread skeleton for new Consumer threading model - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15573) Implement auto-commit on partition assignment revocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15184) New consumer internals refactoring and clean up - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15694) New integration tests to have full coverage for preview - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15554) Update client state machine to align with protocol sending one assignment at a time - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15316) CommitRequestManager not calling RequestState callbacks - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15539) Client should stop fetching while partitions being revoked - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15890) Consumer.poll with long timeout unaware of assigned partitions - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15188) Implement more of the remaining PrototypeAsyncConsumer APIs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15438) Review exception caching logic used for reset/validate positions in async consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15164) Extract reusable logic from OffsetsForLeaderEpochClient - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15562) Ensure fetch offset and commit offset handler handles both timeout and various error types - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15275) Implement consumer group membership state machine - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15280) Implement client support for selecting KIP-848 server-side assignor - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14247) Implement EventHandler interface and DefaultEventHandler for Consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15555) Ensure wakeups are handled correctly in PrototypeAsyncConsumer.poll() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15540) Handle heartbeat and revocation when consumer leaves group - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15631) Do not send new heartbeat request while another one in-flight - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15543) Send HB request right after reconciliation completes - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15278) Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15317) Fix for async consumer access to committed offsets with multiple consumers - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15533) Ensure HeartbeatRequestManager only send out some fields once - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15592) Member does not need to always try to join a group when a groupId is configured - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15544) Enable existing client integration tests for new protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 03:16:00 UTC, 0 replies.
- Re: [PR] KAFKA-14401: Fail kafka log read end requests if underneath work thread is dead [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/19 03:33:12 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14511) Extend AlterIncrementalConfigs API to support group config - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2023/12/19 04:03:00 UTC, 0 replies.
- Re: [PR] KAFKA-15158: Add metrics for RemoteDelete and BuildRemoteLogAuxState [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/19 07:02:47 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15158) Add metrics for RemoteDeleteRequestsPerSec, RemoteDeleteErrorsPerSec, BuildRemoteLogAuxStateRequestsPerSec, BuildRemoteLogAuxStateErrorsPerSec - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/19 07:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15726) KRaft support in ProduceRequestTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2023/12/19 08:50:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15725) KRaft support in FetchRequestTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2023/12/19 08:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15448) Streams StandbyTaskUpdateListener - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/19 08:53:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15448) Streams StandbyTaskUpdateListener - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2023/12/19 08:54:00 UTC, 0 replies.
- Re: [PR] KAFKA-15448: Update upgrade guide for KIP-988 [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/19 09:05:11 UTC, 4 replies.
- [PR] MINOR: improve logging for state management [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/19 09:14:51 UTC, 0 replies.
- Re: [PR] Update Streams API broker compat table [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/19 09:18:32 UTC, 2 replies.
- Re: [PR] MINOR: doc/streams/dsl-api, fix href of "KTable-KTable Foreign-Key Joins" [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2023/12/19 09:26:20 UTC, 1 replies.
- Re: [PR] KAFKA-15739: KRaft support in ResetConsumerGroupOffsetTest [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2023/12/19 11:41:29 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15775) Implement listTopics() and partitionFor() for the AsyncKafkaConsumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2023/12/19 12:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15548) Send GroupConsumerHeartbeatRequest on Consumer.close() - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/19 13:03:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15696) Revoke partitions on Consumer.close() - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/19 13:05:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15723) KRaft support in ListOffsetsRequestTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2023/12/19 14:20:00 UTC, 0 replies.
- [PR] KAFKA-15723: KRaft support in ListOffsetsRequestTest [kafka] - posted by "linzihao1999 (via GitHub)" <gi...@apache.org> on 2023/12/19 14:22:09 UTC, 0 replies.
- [PR] KAFKA-16016: Add docker wrapper in core and remove docker utility script [kafka] - posted by "VedarthConfluent (via GitHub)" <gi...@apache.org> on 2023/12/19 14:27:18 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15000) High vulnerability PRISMA-2023-0067 reported in jackson-core - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/19 14:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15000) High vulnerability PRISMA-2023-0067 reported in jackson-core - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/19 14:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15980) Add KIP-1001 CurrentControllerId metric - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/19 14:39:00 UTC, 0 replies.
- Re: [PR] KAFKA-14945: Add Serializer#serializeToByteBuffer() to reduce memory copying [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/19 14:47:03 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15719) KRaft support in OffsetsForLeaderEpochRequestTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2023/12/19 15:19:00 UTC, 0 replies.
- Re: [PR] KAFKA-15057: Use new interface from zstd-jni [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/19 15:20:28 UTC, 0 replies.
- [PR] KAFKA-15719: KRaft support in OffsetsForLeaderEpochRequestTest [kafka] - posted by "linzihao1999 (via GitHub)" <gi...@apache.org> on 2023/12/19 15:22:29 UTC, 0 replies.
- [PR] Implement RemoteLogSizeBytes [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2023/12/19 16:08:41 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-16032) Review inconsistent error handling of OffsetFetch and OffsetCommit responses - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/19 16:46:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16032) Review inconsistent error handling of OffsetFetch and OffsetCommit responses - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/19 16:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16032) Review inconsistent error handling of OffsetFetch and OffsetCommit responses - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/19 16:50:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16033) Review retry logic of OffsetFetch and OffsetCommit responses - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/12/19 17:05:00 UTC, 0 replies.
- [PR] Update Streams API broker compat table for AK 3.7 [kafka] - posted by "JimGalasyn (via GitHub)" <gi...@apache.org> on 2023/12/19 19:45:39 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15279) Implement client support for KIP-848 client-side assigner RPCs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:49:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-15283) Add support for topic ID-related Consumer changes - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15327) Client consumer should commit offsets on close - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15556) Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16033) Review retry logic of OffsetFetch and OffsetCommit responses - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15697) Add local assignor and ensure it cannot be used with server side assignor - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15773) Group protocol configuration should be validated - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15250) DefaultBackgroundThread is running tight loop - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15588) Purge the unsent offset commits/fetches when the member is fenced/failed - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15848) Consumer API timeout inconsistent between ConsumerDelegate implementations - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15553) Review committed offset refresh logic - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:52:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15456) Add support for OffsetFetch version 9 in consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:53:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15455) Add support for OffsetCommit version 9 in consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:53:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15515) Remove duplicated integration tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15615) Improve handling of fetching during metadata updates - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15173) Consumer event queues should be bounded - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15542) Release member assignments on errors - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15305) The background thread should try to process the remaining task until the shutdown timer is expired - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15282) Implement client support for KIP-848 client-side assignors - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15283) Add support for topic ID-related Consumer changes - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15538) Client support for java regex based subscription - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/19 19:56:00 UTC, 2 replies.
- [jira] [Commented] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "Sabit (Jira)" <ji...@apache.org> on 2023/12/19 22:20:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "Sabit (Jira)" <ji...@apache.org> on 2023/12/19 22:22:00 UTC, 4 replies.
- [jira] [Commented] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/19 23:13:00 UTC, 0 replies.
- Re: [PR] KAFKA-15592: Allow member to not sending a heartbeat when a group ID is configured [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/20 00:49:57 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/20 07:41:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/20 07:43:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/20 07:43:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16016) Migrate utility scripts to kafka codebase - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/20 10:58:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16035) add integration test for ExpiresPerSec and RemoteLogSizeComputationTime metrics - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/20 12:04:00 UTC, 0 replies.
- Re: [PR] KAFKA-16013: Added test for ExpiresPerSec metric [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/20 12:05:21 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15529) Flaky test ReassignReplicaShrinkTest.executeTieredStorageTest - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/20 12:13:00 UTC, 2 replies.
- [PR] [WIP] MINOR: fix flaky test [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/20 12:38:04 UTC, 0 replies.
- [jira] [Created] (KAFKA-16036) Add `group.coordinator.rebalance.protocols` and publish all new configs - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/20 13:14:00 UTC, 0 replies.
- [PR] KAFKA-16036; Add `group.coordinator.rebalance.protocols` and publish all new configs [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/20 13:21:38 UTC, 4 replies.
- Re: [PR] KAFKA-16013: Throw an exception in DelayedRemoteFetch for follower fetch replicas. [kafka] - posted by "satishd (via GitHub)" <gi...@apache.org> on 2023/12/20 14:27:57 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2023/12/20 14:47:00 UTC, 0 replies.
- [PR] MINOR: skip 'zinc' phase from gradle dependency-check plugin [kafka] - posted by "raboof (via GitHub)" <gi...@apache.org> on 2023/12/20 14:59:40 UTC, 0 replies.
- Re: [PR] KafkaConsumer not respecting max.poll.record when subscribing to more than 1 topics. [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/20 15:51:27 UTC, 0 replies.
- Re: [PR] Prototype take 2 [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/20 15:52:02 UTC, 0 replies.
- Re: [PR] Prototyping Rebalance Protocol [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/20 15:52:05 UTC, 0 replies.
- Re: [PR] KAFKA-13421 - fix flaky ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2023/12/20 15:52:12 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13922) Unable to generate coverage reports for the whole project - posted by "Andras Katona (Jira)" <ji...@apache.org> on 2023/12/20 16:15:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-13922) Unable to generate coverage reports for the whole project - posted by "Andras Katona (Jira)" <ji...@apache.org> on 2023/12/20 16:16:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16037) Upgrade existing system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/20 18:42:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15691) Add new system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/20 18:43:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16037) Upgrade existing system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2023/12/20 18:43:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16038) Periodic Logging fo Current Assignment - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2023/12/20 18:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16038) Periodic Logging of Current Assignment - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2023/12/20 18:59:00 UTC, 0 replies.
- [PR] MINOR: Kafka-16027 Refactor MetadataTest#testUpdatePartitionLeadership [kafka] - posted by "Alexander-Aghili (via GitHub)" <gi...@apache.org> on 2023/12/20 23:53:25 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16027) Refactor MetadataTest#testUpdatePartitionLeadership - posted by "Alexander Aghili (Jira)" <ji...@apache.org> on 2023/12/20 23:58:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16039) RecordHeaders supports the addAll method - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2023/12/21 03:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16039) RecordHeaders supports the addAll method - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2023/12/21 04:00:00 UTC, 1 replies.
- [jira] (KAFKA-15739) KRaft support in ResetConsumerGroupOffsetTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2023/12/21 04:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16014) Implement RemoteLogSizeComputationTime, RemoteLogSizeBytes, RemoteLogMetadataCount - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/21 06:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16038) Periodic Logging of Current Assignment - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/21 08:36:00 UTC, 0 replies.
- [PR] KAFKA-16035: add tests for remoteLogSizeComputationTime/remoteFetchExpiresPerSec metrics [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/21 09:25:31 UTC, 2 replies.
- [PR] MINOR: Use --no-daemon when building with Jenkins [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/21 10:09:03 UTC, 1 replies.
- Re: [PR] KAFKA-14888: Added remote log segments retention functionality based on time and size. [kafka] - posted by "iit2009060 (via GitHub)" <gi...@apache.org> on 2023/12/21 11:26:19 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15241) Compute tiered offset by keeping the respective epochs in scope. - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2023/12/21 12:15:00 UTC, 0 replies.
- [jira] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage. - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/21 12:38:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16036) Add `group.coordinator.rebalance.protocols` and publish all new configs - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/21 12:47:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16040) Rename `Generic` to `Classic` - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/21 12:48:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13950) Resource leak at multiple places in the code - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/21 12:49:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage. - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/21 12:51:00 UTC, 1 replies.
- [PR] KAFKA-16040; Rename `Generic` to `Classic` [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/21 12:52:50 UTC, 12 replies.
- [jira] [Updated] (KAFKA-15388) Handle topics that were having compaction as retention earlier are changed to delete only retention policy and onboarded to tiered storage. - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/21 12:55:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16040) Rename `Generic` to `Classic` - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/21 12:55:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16030) new group coordinator should check if partition goes offline during load - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/21 14:19:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15456) Add support for OffsetFetch version 9 in consumer - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/21 14:50:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 ConfigType moved to server-common [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2023/12/21 15:15:34 UTC, 10 replies.
- [jira] [Created] (KAFKA-16041) Replace Afterburn module with Blackbird - posted by "Mario Fiore Vitale (Jira)" <ji...@apache.org> on 2023/12/21 15:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16042) Quota Metrics based on per topic-partition produce/fetch byte rate - posted by "Afshin Moazami (Jira)" <ji...@apache.org> on 2023/12/21 16:32:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16043) Add Quota configuration for topics - posted by "Afshin Moazami (Jira)" <ji...@apache.org> on 2023/12/21 16:37:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16044) Throttling using Topic Partition Quota - posted by "Afshin Moazami (Jira)" <ji...@apache.org> on 2023/12/21 16:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16041) Replace Afterburn module with Blackbird - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2023/12/21 16:45:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-10897) kafka quota optimization - posted by "Afshin Moazami (Jira)" <ji...@apache.org> on 2023/12/21 16:56:00 UTC, 0 replies.
- [PR] KAFKA-15388: Handling remote segment read in case of log compaction [kafka] - posted by "iit2009060 (via GitHub)" <gi...@apache.org> on 2023/12/21 17:43:51 UTC, 12 replies.
- Re: [PR] KAFKA-15303: Avoid unnecessary re-serialization in FK-join [kafka] - posted by "CharlyRien (via GitHub)" <gi...@apache.org> on 2023/12/21 18:27:08 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16027) Refactor MetadataTest#testUpdatePartitionLeadership - posted by "Alexander Aghili (Jira)" <ji...@apache.org> on 2023/12/21 19:46:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16045) ZkMigrationIntegrationTest.testMigrateTopicDeletion flaky - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/21 21:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16045) ZkMigrationIntegrationTest.testMigrateTopicDeletion flaky - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/21 21:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16040) Rename `Generic` to `Classic` - posted by "David Jacot (Jira)" <ji...@apache.org> on 2023/12/21 21:45:00 UTC, 0 replies.
- [PR] fix stream-stream-join store types [kafka] - posted by "agavra (via GitHub)" <gi...@apache.org> on 2023/12/22 01:02:26 UTC, 0 replies.
- [jira] [Created] (KAFKA-16046) Stream Stream Joins fail after restoration with deserialization exceptions - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2023/12/22 01:03:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16046) Stream Stream Joins fail after restoration with deserialization exceptions - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2023/12/22 01:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16046) Stream Stream Joins fail after restoration with deserialization exceptions - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2023/12/22 01:04:00 UTC, 2 replies.
- Re: [PR] KAFKA-16014: Implement RemoteLogSizeBytes [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/22 06:52:20 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16035) add integration test for ExpiresPerSec and RemoteLogSizeComputationTime metrics - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/22 07:04:00 UTC, 0 replies.
- [PR] MINOR: Exit catcher should be reset after the cluster is shutdown [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/22 08:59:38 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15301) [Tiered Storage] Historically compacted topics send request to remote for active segment during consume - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/22 09:28:00 UTC, 1 replies.
- [PR] MINOR: Close RemoteLogManager in RemoteLogManagerTest [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2023/12/22 09:31:30 UTC, 2 replies.
- [PR] DNM: test [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/22 10:05:50 UTC, 1 replies.
- Re: [PR] KAFKA-16046: fix stream-stream-join store types [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/22 10:20:05 UTC, 4 replies.
- [PR] MINOR: set test global timeout as 10 mins [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/22 12:36:09 UTC, 2 replies.
- [jira] [Commented] (KAFKA-10875) offsetsForTimes returns null for some partitions when it shouldn't? - posted by "Hugo Abreu (Jira)" <ji...@apache.org> on 2023/12/22 15:19:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-10875) offsetsForTimes returns null for some partitions when it shouldn't? - posted by "Hugo Abreu (Jira)" <ji...@apache.org> on 2023/12/22 15:22:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16046) Stream Stream Joins fail after restoration with deserialization exceptions - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2023/12/22 15:51:00 UTC, 0 replies.
- Re: [PR] MINOR: Refactor to only require one stopPartitions helper [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/22 16:12:54 UTC, 1 replies.
- [PR] Duplicate method; The QuotaUtils one is used. [kafka] - posted by "afshing (via GitHub)" <gi...@apache.org> on 2023/12/22 19:20:59 UTC, 7 replies.
- [jira] [Created] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out - posted by "Angelos Kaltsikis (Jira)" <ji...@apache.org> on 2023/12/22 21:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing the whole connector - posted by "Angelos Kaltsikis (Jira)" <ji...@apache.org> on 2023/12/22 21:04:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing the whole connector - posted by "Angelos Kaltsikis (Jira)" <ji...@apache.org> on 2023/12/22 21:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector - posted by "Angelos Kaltsikis (Jira)" <ji...@apache.org> on 2023/12/22 21:06:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16012) Incomplete range assignment in consumer - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2023/12/23 00:10:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16027) Refactor MetadataTest#testUpdatePartitionLeadership - posted by "Alexander Aghili (Jira)" <ji...@apache.org> on 2023/12/23 02:10:00 UTC, 0 replies.
- Re: [PR] KAFKA-9337 simplify mm2 initial configs [kafka] - posted by "Gakhramanzode (via GitHub)" <gi...@apache.org> on 2023/12/23 13:26:22 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15983) Kafka-acls should return authorization already done if repeating work is issued - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2023/12/23 18:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15749) KRaft support in KafkaMetricReporterClusterIdTest - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2023/12/23 19:03:00 UTC, 0 replies.
- [PR] KAFKA-14511: extend AlterIncrementalConfigs API to support group config [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2023/12/24 08:25:59 UTC, 0 replies.
- [jira] [Created] (KAFKA-16048) Test failure kafka.admin.ConfigCommandTest.shouldNotSupportAlterClientMetricsWithZookeeper - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/24 20:09:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16048) Test failure kafka.admin.ConfigCommandTest.shouldNotSupportAlterClientMetricsWithZookeeper - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/24 20:10:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15206) Flaky test RemoteIndexCacheTest.testClose() - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/24 20:14:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16021) Eagerly load Charset for StringSerializer/StringDeserializer - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/24 20:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16021) Eagerly load Charset for StringSerializer/StringDeserializer - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/24 20:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15996) json serializer too slow - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/24 20:48:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15996) json serializer too slow - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/24 20:49:00 UTC, 0 replies.
- Re: [PR] MINOR: Upgrade Zstd-jni to 1.5.5-11 [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/24 22:56:54 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16048) Test failure kafka.admin.ConfigCommandTest.shouldNotSupportAlterClientMetricsWithZookeeper - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2023/12/24 23:19:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15089) Consolidate all the group coordinator configs - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2023/12/25 02:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16048) Test failure kafka.admin.ConfigCommandTest.shouldNotSupportAlterClientMetricsWithZookeeper - posted by "Nikolay Izhikov (Jira)" <ji...@apache.org> on 2023/12/25 03:19:00 UTC, 0 replies.
- [PR] KAFKA-16048 Fix shouldNotSupportAlterClientMetricsWithZookeeper [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2023/12/25 03:31:03 UTC, 3 replies.
- Re: [PR] KAFKA-15307: Update/errors for deprecated config [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/25 03:33:13 UTC, 0 replies.
- Re: [PR] KAFKA-15497 Refactor build.gradle and split each module configuration… [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/25 03:33:15 UTC, 0 replies.
- Re: [PR] KAFKA-15307: update/note deprecated configs [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/25 03:33:20 UTC, 0 replies.
- Re: [PR] KAFKA-16027: MINOR Refactor MetadataTest#testUpdatePartitionLeadership [kafka] - posted by "Alexander-Aghili (via GitHub)" <gi...@apache.org> on 2023/12/25 04:29:58 UTC, 1 replies.
- [PR] MINOR: [kafka] - posted by "IBeyondy (via GitHub)" <gi...@apache.org> on 2023/12/25 10:55:24 UTC, 0 replies.
- [PR] KAFKA-14588 [WIP] ConfigCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2023/12/25 12:00:31 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15619) Deleted topics will come back again - posted by "Deng Ziming (Jira)" <ji...@apache.org> on 2023/12/25 12:20:00 UTC, 0 replies.
- [PR] MINOR: New year code clean up (part 1) [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/25 16:07:16 UTC, 0 replies.
- Re: [PR] MINOR: Fix NullPointerException in ReplicaFetcherThreadTest testcase. [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/25 16:29:58 UTC, 2 replies.
- [PR] MINOR: New year code cleanup - include final keyword [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/25 17:23:20 UTC, 9 replies.
- [jira] [Created] (KAFKA-16049) Can you please share tutorial how to run Latest Kafka (3.6.0) - posted by "Petr Kostroun (Jira)" <ji...@apache.org> on 2023/12/25 18:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16049) Can you please share tutorial how to run Latest Kafka (3.6.0) with SASL_SSL - posted by "Petr Kostroun (Jira)" <ji...@apache.org> on 2023/12/25 18:41:00 UTC, 2 replies.
- [PR] KAFKA-16046: also fix stores for outer join [kafka] - posted by "agavra (via GitHub)" <gi...@apache.org> on 2023/12/25 22:00:04 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/26 00:06:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16022) AsyncKafkaConsumer sometimes complains "No current assignment for partition {}" - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/26 00:12:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/26 01:15:00 UTC, 0 replies.
- [PR] MONOR: Improve code style [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2023/12/26 02:56:09 UTC, 0 replies.
- Re: [PR] [WIP]MINOR: Find test [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/26 03:33:22 UTC, 0 replies.
- Re: [PR] KAFKA-14808: fix leaderless partition issue when controller removes u… [kafka] - posted by "songnon (via GitHub)" <gi...@apache.org> on 2023/12/26 07:22:43 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16016) Migrate utility scripts to kafka codebase - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 09:00:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16026) AsyncConsumer does not send a poll event to the background thread - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 09:01:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 ConfigEntityName move to server-common [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2023/12/26 09:05:29 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15818) Implement max poll interval - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 09:06:00 UTC, 0 replies.
- [PR] KAFKA-14588 [WIP] ZK properties moved to ZkConfig [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2023/12/26 09:09:01 UTC, 0 replies.
- [jira] [Created] (KAFKA-16050) consumer was removed from group，but still can poll data from kafka, data duplicate - posted by "Xin (Jira)" <ji...@apache.org> on 2023/12/26 09:48:00 UTC, 0 replies.
- [PR] MINOR: Fix 3.7 build failure by removing a superfluous empty snapshot file [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2023/12/26 10:38:21 UTC, 1 replies.
- Re: [PR] MINOR: Improve code style [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/26 11:20:38 UTC, 1 replies.
- [jira] [Created] (KAFKA-16051) Deadlock on connector initialization - posted by "Octavian Ciubotaru (Jira)" <ji...@apache.org> on 2023/12/26 16:35:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16047) Source connector with EOS enabled have some InitProducerId requests timing out, effectively failing all the tasks & the whole connector - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:42:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16051) Deadlock on connector initialization - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:49:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15333) Flaky build failure throwing Connect Exception: Could not connect to server.... - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15203) Remove dependency on Reflections - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15310) Add timezone configuration option in TimestampConverter from connectors - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:55:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15570) Add unit tests for MemoryConfigBackingStore - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15841) Add Support for Topic-Level Partitioning in Kafka Connect - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15524) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testResetSinkConnectorOffsetsZombieSinkTasks - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15339) Transient I/O error happening in appending records could lead to the halt of whole cluster - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15335) Support custom SSL configuration for Kafka Connect RestServer - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15855) RFC 9266: Channel Bindings for TLS 1.3 support | SCRAM-SHA-*-PLUS variants - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15470) Allow creating connectors in a stopped state - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15680) Partition-Count is not getting updated Correctly in the Incremental Co-operative Rebalancing(ICR) Mode of Rebalancing - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15407) Not able to connect to kafka from the Private NLB from outside the VPC account - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16051) Deadlock on connector initialization - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16041) Replace Afterburn module with Blackbird - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15912) Parallelize conversion and transformation steps in Connect - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15888) DistributedHerder log context should not use the same client ID for each Connect worker by default - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:57:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15976) KIP-995: Allow users to specify initial offsets while creating connectors - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/26 16:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12622) Automate LICENSE file validation - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 19:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15752) KRaft support in SaslSslAdminIntegrationTest - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2023/12/26 19:30:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16007) ZK migrations can be slow for large clusters - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:01:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15969) Align RemoteStorageThreadPool metrics name with KIP-405 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:02:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15994) Add complex example compose file - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15994) Add complex example compose file - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:02:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15904) Downgrade tests are failing with directory.id - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:08:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15904) Downgrade tests are failing with directory.id - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15864) Add more tests asserting the log-start-offset, local-log-start-offset, and HW/LSO/LEO in rolling over segments with tiered storage. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15864) Add more tests asserting the log-start-offset, local-log-start-offset, and HW/LSO/LEO in rolling over segments with tiered storage. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:10:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15857) Introduce LocalLogStartOffset and TieredOffset in OffsetSpec. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:12:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15857) Introduce LocalLogStartOffset and TieredOffset in OffsetSpec. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:12:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15823) NodeToControllerChannelManager: authentication error prevents controller update - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15817) Avoid reconnecting to the same IP address if multiple addresses are available - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:14:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15817) Avoid reconnecting to the same IP address if multiple addresses are available - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:14:00 UTC, 0 replies.
- [jira] (KAFKA-15817) Avoid reconnecting to the same IP address if multiple addresses are available - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:14:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15823) NodeToControllerChannelManager: authentication error prevents controller update - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15809) Update broker's metadata schema to include TS enable status - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15809) Update broker's metadata schema to include TS enable status - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:15:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15780) Wait for consistent kraft metadata when creating topics in tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:16:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15795) Support fetch(fromKey, toKey, from, to) to WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15780) Wait for consistent kraft metadata when creating topics in tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:16:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15780) Wait for consistent kraft metadata when creating topics in tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:16:00 UTC, 0 replies.
- [jira] (KAFKA-15780) Wait for consistent kraft metadata when creating topics in tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15795) Support fetch(fromKey, toKey, from, to) to WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:16:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15646) Update ReassignPartitionsIntegrationTest once JBOD available - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15646) Update ReassignPartitionsIntegrationTest once JBOD available - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15612) Followup on whether the segment indexes need to be materialized or flushed before they are passed to RSM for writing them to tiered storage. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15767) Redesign TransactionManager to avoid use of ThreadLocal - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15767) Redesign TransactionManager to avoid use of ThreadLocal - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:17:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15576) Add 3.6.0 to broker/client and streams upgrade/compatibility tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15576) Add 3.6.0 to broker/client and streams upgrade/compatibility tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15612) Followup on whether the segment indexes need to be materialized or flushed before they are passed to RSM for writing them to tiered storage. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15493) Ensure system tests work with Java 21 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:21:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15493) Ensure system tests work with Java 21 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15480) Add RemoteStorageInterruptedException - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:21:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15752) KRaft support in SaslSslAdminIntegrationTest - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2023/12/26 20:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15420) Kafka Tiered Storage V1 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15455) Add support for OffsetCommit version 9 in consumer - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15480) Add RemoteStorageInterruptedException - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15420) Kafka Tiered Storage V1 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15411) DelegationTokenEndToEndAuthorizationWithOwnerTest is Flaky - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:23:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15419) Flaky DescribeClusterRequestTest - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15419) Flaky DescribeClusterRequestTest - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15411) DelegationTokenEndToEndAuthorizationWithOwnerTest is Flaky - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:24:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15381) Controller waiting for migration should only allow failover when transactions are supported - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15381) Controller waiting for migration should only allow failover when transactions are supported - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15376) Explore options of removing data earlier to the current leader's leader epoch lineage for topics enabled with tiered storage. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:25:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15331) Handle remote log enabled topic deletion when leader is not available - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:26:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15331) Handle remote log enabled topic deletion when leader is not available - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15205) Race condition in ShutdownableThread causes InterruptedException - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:27:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15327) Client consumer should commit offsets on close - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15205) Race condition in ShutdownableThread causes InterruptedException - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15214) Add metrics for OffsetOutOfRangeException when tiered storage is enabled - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15301) [Tiered Storage] Historically compacted topics send request to remote for active segment during consume - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:27:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15214) Add metrics for OffsetOutOfRangeException when tiered storage is enabled - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15166) Add deletePartition API to the RemoteStorageManager - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15195) Regenerate segment-aligned producer snapshots when upgrading to a Kafka version supporting Tiered Storage - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15197) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTranslationBehindReplicationFlow() - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15195) Regenerate segment-aligned producer snapshots when upgrading to a Kafka version supporting Tiered Storage - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15197) Flaky test MirrorConnectorsIntegrationExactlyOnceTest.testOffsetTranslationBehindReplicationFlow() - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15147) Measure pending and outstanding Remote Segment operations - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15495) KRaft partition truncated when the only ISR member restarts with an empty disk - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2023/12/26 20:30:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15140) Improve TopicCommandIntegrationTest to be less flaky - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15057) Use new interface ZstdBufferDecompressingStreamNoFinalizer from zstd-jni - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15132) Implement disable & re-enablement for Tiered Storage - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15132) Implement disable & re-enablement for Tiered Storage - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15094) Add RemoteIndexCache metrics like misses/evictions/load-failures. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15057) Use new interface ZstdBufferDecompressingStreamNoFinalizer from zstd-jni - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:32:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:32:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14954) Use BufferPools to optimize allocation in RemoteLogInputStream - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14945) Add Serializer#serializeToByteBuffer() to reduce memory copying - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15038) Use topic id/name mapping from the Metadata cache in the RemoteLogManager - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14928) Metrics collection contends on lock with log cleaning - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:33:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:33:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14928) Metrics collection contends on lock with log cleaning - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14915) Option to consume multiple partitions that have their data in remote storage for the target offsets. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14892) Harmonize package names in storage module - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14908) Sporadic "Address already in use" when starting kafka cluster embedded within tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14892) Harmonize package names in storage module - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14877) refactor InMemoryLeaderEpochCheckpoint - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14908) Sporadic "Address already in use" when starting kafka cluster embedded within tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14911) Add system tests for rolling upgrade path of KIP-904 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:34:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14482) Move LogLoader to storage module - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14683) Replace EasyMock and PowerMock with Mockito in WorkerSinkTaskTest - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:36:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14482) Move LogLoader to storage module - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14683) Replace EasyMock and PowerMock with Mockito in WorkerSinkTaskTest - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14403) Snapshot failure metrics - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:37:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14323) KRaft broker time based snapshots - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:37:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-14403) Snapshot failure metrics - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14186) Add unit tests for BatchFileWriter - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14186) Add unit tests for BatchFileWriter - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14302) Infinite probing rebalance if a changelog topic got emptied - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:38:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14145) Faster propagation of high-watermark in KRaft topic partitions - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14323) KRaft broker time based snapshots - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:38:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14132) Remaining PowerMock to Mockito tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 20:43:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15493) Ensure system tests work with Java 21 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2023/12/26 20:47:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:37:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13421) Fix ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13560) Load indexes and data in async manner in the critical path of replica fetcher threads. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:39:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:40:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13152) Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes" - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13355) Shutdown broker eventually when unrecoverable exceptions like IOException encountered in RLMM. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15620) Duplicate remote log DELETE_SEGMENT metadata is generated when there are multiple leader epochs in the segment - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 21:42:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-12679) Rebalancing a restoring or running task may cause directory livelocking with newly created task - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:18:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15300) Include remotelog size in complete log size and also add local log size and remote log size separately in kafka-log-dirs tool. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-13097) Handle the requests gracefully to publish the events in TopicBasedRemoteLogMetadataManager when it is not yet initialized. - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-12622) Automate LICENSE file validation - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14690) OffsetCommit API Version 9 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:20:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit() - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9578) Kafka Tiered Storage - System Tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-12319) Flaky test ConnectionQuotasTest.testListenerConnectionRateLimitWhenActualRateAboveLimit() - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9693) Kafka latency spikes caused by log segment flush on roll - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-9578) Kafka Tiered Storage - System Tests - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:21:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-6527) Transient failure in DynamicBrokerReconfigurationTest.testDefaultTopicConfig - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:22:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-8280) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2023/12/26 22:22:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions() - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/27 02:30:00 UTC, 0 replies.
- Re: [PR] KAFKA-15062: Adding ppc64le build stage [kafka] - posted by "Vaibhav-Nazare (via GitHub)" <gi...@apache.org> on 2023/12/27 05:52:22 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions() - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/27 06:23:00 UTC, 1 replies.
- [PR] MINOR: close leaking threads in replica manager tests [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/27 08:36:39 UTC, 14 replies.
- [PR] KAFKA-16047: Leverage the fenceProducers timeout in the InitProducerId [kafka] - posted by "akaltsikis (via GitHub)" <gi...@apache.org> on 2023/12/27 09:58:23 UTC, 3 replies.
- Re: [PR] MINOR: New year code clean up - misc [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/27 10:06:09 UTC, 0 replies.
- [jira] [Created] (KAFKA-16052) OOM in Kafka test suite - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/27 12:43:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16053) Fix leaked Default DirectoryService - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/27 12:45:00 UTC, 0 replies.
- [PR] KAFKA-16053: Fix leaks of KDC server in tests [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/27 12:48:37 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16053) Fix leaked Default DirectoryService - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/27 12:59:00 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16052) OOM in Kafka test suite - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/27 13:07:00 UTC, 28 replies.
- [jira] [Updated] (KAFKA-16052) OOM in Kafka test suite - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/27 13:07:00 UTC, 15 replies.
- [jira] [Created] (KAFKA-16054) Sudden 100% CPU on a broker - posted by "Oleksandr Shulgin (Jira)" <ji...@apache.org> on 2023/12/27 13:50:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16054) Sudden 100% CPU on a broker - posted by "Oleksandr Shulgin (Jira)" <ji...@apache.org> on 2023/12/27 13:53:00 UTC, 3 replies.
- [jira] [Comment Edited] (KAFKA-16052) OOM in Kafka test suite - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/27 14:02:00 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-15904) Downgrade tests are failing with directory.id - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2023/12/27 14:43:00 UTC, 0 replies.
- [PR] KAFKA-16051: Fixed deadlock in StandaloneHerder [kafka] - posted by "developster (via GitHub)" <gi...@apache.org> on 2023/12/27 15:21:47 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15495) Partition truncated when the only ISR member restarts with an empty disk - posted by "Ron Dagostino (Jira)" <ji...@apache.org> on 2023/12/27 15:41:00 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-16044) Throttling using Topic Partition Quota - posted by "Afshin Moazami (Jira)" <ji...@apache.org> on 2023/12/27 15:58:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16043) Add Quota configuration for topics - posted by "Afshin Moazami (Jira)" <ji...@apache.org> on 2023/12/27 15:58:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15495) Partition truncated when the only ISR member restarts with an empty disk - posted by "Ron Dagostino (Jira)" <ji...@apache.org> on 2023/12/27 18:23:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16045) ZkMigrationIntegrationTest.testMigrateTopicDeletion flaky - posted by "David Arthur (Jira)" <ji...@apache.org> on 2023/12/27 19:53:00 UTC, 0 replies.
- [PR] WIP -- clear mocks in AbstractCoordinatorConcurrencyTest [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/27 20:48:52 UTC, 1 replies.
- [PR] KAFKA-16045 Fix flaky testMigrateTopicDeletions [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2023/12/27 20:53:29 UTC, 0 replies.
- [jira] [Created] (KAFKA-16055) Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders - posted by "Kohei Nozaki (Jira)" <ji...@apache.org> on 2023/12/27 22:37:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15997) Ensure fairness in the uniform assignor - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2023/12/28 01:37:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-15997) Ensure fairness in the uniform assignor - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2023/12/28 01:40:00 UTC, 1 replies.
- Re: [PR] KAFKA-15344: Commit leader epoch where possible [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/28 03:33:14 UTC, 0 replies.
- Re: [PR] MINOR: Range assignor changes [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/28 03:33:20 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15948) Refactor AsyncKafkaConsumer shutdown - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/28 03:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15948) Refactor AsyncKafkaConsumer shutdown - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2023/12/28 04:08:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16056) Worker poll timeout expiry can lead to Duplicate task assignments. - posted by "Sagar Rao (Jira)" <ji...@apache.org> on 2023/12/28 06:27:00 UTC, 0 replies.
- [PR] MINOR: create a real dummy replicaManager instance to save memory [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/28 08:59:47 UTC, 0 replies.
- [jira] [Created] (KAFKA-16057) Admin Client connections.max.idle.ms should be 9 minutes by default - posted by "Marcin Kuthan (Jira)" <ji...@apache.org> on 2023/12/28 10:10:00 UTC, 0 replies.
- [PR] MINOR: close controllerApi instance to avoid thread leaking [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/28 11:53:49 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/28 12:13:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/28 12:14:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread? - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/28 12:30:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16058) Fix leaked in ControllerApiTest - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/28 12:43:00 UTC, 0 replies.
- Re: [PR] KAFKA-16052: create a real dummy replicaManager instance to save memory [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/28 14:18:27 UTC, 3 replies.
- Re: [PR] KAFKA-16058: close controllerApi instance to avoid thread leaking [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/28 15:36:28 UTC, 5 replies.
- [jira] [Updated] (KAFKA-16058) Fix leaked in ControllerApiTest - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/28 17:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16059) Fix leak of ExpirationReaper-1-AlterAcls threads in :core:test - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/28 17:41:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16059) Fix trhead l - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/28 17:41:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16059) Fix leak of ExpirationReaper-1-AlterAcls threads in :core:test - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/28 18:00:00 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16034) AsyncKafkaConsumer will get Invalid Request error when trying to rejoin on fenced/unknown member Id - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2023/12/28 19:18:00 UTC, 0 replies.
- Re: [PR] [MINOR] More image replay test cases [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2023/12/28 19:23:13 UTC, 0 replies.
- [PR] init commit - no config [kafka] - posted by "afshing (via GitHub)" <gi...@apache.org> on 2023/12/28 19:32:07 UTC, 0 replies.
- Re: [PR] KAFKA-16015: Fix custom timeouts overwritten by defaults [kafka] - posted by "sciclon2 (via GitHub)" <gi...@apache.org> on 2023/12/28 21:28:10 UTC, 3 replies.
- [jira] [Commented] (KAFKA-15742) KRaft support in GroupCoordinatorIntegrationTest - posted by "Dmitry (Jira)" <ji...@apache.org> on 2023/12/28 21:48:00 UTC, 1 replies.
- [PR] KAFKA-15742 KRaft support in GroupCoordinatorIntegrationTest [kafka] - posted by "wernerdv (via GitHub)" <gi...@apache.org> on 2023/12/28 22:04:15 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-15742) KRaft support in GroupCoordinatorIntegrationTest - posted by "Dmitry (Jira)" <ji...@apache.org> on 2023/12/28 22:08:00 UTC, 1 replies.
- [jira] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "Sabit (Jira)" <ji...@apache.org> on 2023/12/28 22:16:00 UTC, 0 replies.
- [PR] KAFKA-15987: Refactor ReplicaManager code for transaction verification [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2023/12/28 23:53:19 UTC, 0 replies.
- [jira] [Created] (KAFKA-16060) Some questions about tiered storage capabilities - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2023/12/29 01:50:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16061) JBOD follow-ups - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 01:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15359) log.dir.failure.timeout.ms configuration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 01:59:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15359) Support log.dir.failure.timeout.ms configuration for JBOD - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 01:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16061) KRaft JBOD follow-ups and improvements - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 01:59:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15367) Test KRaft non-JBOD -> JBOD migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 02:01:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15368) Test ZK JBOD to KRaft migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 02:02:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15649) Handle directory failure timeout - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 02:02:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15650) Data-loss on leader shutdown right after partition creation? - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 02:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15650) Data-loss on leader shutdown right after partition creation? - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 02:04:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14127) KIP-858: Handle JBOD broker disk failure in KRaft - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 02:05:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15955) Migrating ZK brokers send dir assignments - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2023/12/29 02:05:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16050) consumer was removed from group，but still can poll data from kafka, data duplicate - posted by "Xin (Jira)" <ji...@apache.org> on 2023/12/29 03:05:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16050) consumer was removed from group，but still can poll data from kafka, data duplicate - posted by "Xin (Jira)" <ji...@apache.org> on 2023/12/29 03:06:00 UTC, 0 replies.
- [PR] KAFKA-16025: Fix orphaned locks when rebalancing and store cleanup race on unassigned task directories [kafka] - posted by "sanepal (via GitHub)" <gi...@apache.org> on 2023/12/29 04:06:18 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16059) Fix leak of ExpirationReaper-1-AlterAcls threads in :core:test - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/29 04:34:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16015) kafka-leader-election timeout values always overwritten by default values - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 09:56:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16060) Some questions about tiered storage capabilities - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 10:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16060) Some questions about tiered storage capabilities - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 10:29:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16059) Fix leak of ExpirationReaper-1-AlterAcls threads in :core:test - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 10:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15964) Flaky test: testHighAvailabilityTaskAssignorLargeNumConsumers – org.apache.kafka.streams.processor.internals.StreamsAssignmentScaleTest - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2023/12/29 10:35:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16062) Upgrade mockito to 5.8.0 - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 11:03:00 UTC, 0 replies.
- [PR] KAFKA-16062: Upgrade mockito to 5.8.0 [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/29 11:04:01 UTC, 2 replies.
- [jira] [Created] (KAFKA-16063) Fix leaked ApplicationShutdownHooks in EndToEndAuthorizationTests - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 11:42:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16063) Fix leaked ApplicationShutdownHooks in EndToEndAuthorizationTests - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 11:42:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-16064) improve ControllerApiTest - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/29 11:52:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16064) improve ControllerApiTest - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/29 11:53:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16065) Fix leak in DelayedOperationTest - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/29 12:05:00 UTC, 0 replies.
- [PR] KAFKA-16065: close DelayedFuturePurgatory [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2023/12/29 12:08:58 UTC, 4 replies.
- [jira] [Assigned] (KAFKA-16063) Fix leaked ApplicationShutdownHooks in EndToEndAuthorizationTests - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/29 12:09:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16064) improve ControllerApiTest - posted by "Dmitry (Jira)" <ji...@apache.org> on 2023/12/29 12:23:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27 - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 12:31:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16064) improve ControllerApiTest - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 12:39:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27 - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 12:40:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15742) KRaft support in GroupCoordinatorIntegrationTest - posted by "Dmitry (Jira)" <ji...@apache.org> on 2023/12/29 12:54:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16067) Refactoring ConsumerGroupListing + add test - posted by "Svyatoslav (Jira)" <ji...@apache.org> on 2023/12/29 12:56:00 UTC, 0 replies.
- [PR] KAFKA-16064: Improve ControllerApiTest [kafka] - posted by "wernerdv (via GitHub)" <gi...@apache.org> on 2023/12/29 13:00:23 UTC, 1 replies.
- [PR] KAFKA-16067 Refactoring ConsumerGroupListing + add test [kafka] - posted by "rykovsi (via GitHub)" <gi...@apache.org> on 2023/12/29 13:32:45 UTC, 0 replies.
- [PR] KAFKA-16059: Fix thread leak KafkaAPIsTest [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/29 14:06:15 UTC, 1 replies.
- [PR] KAFKA-16052: Create a real dummy replicaManager instance to save heap memory [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/29 14:14:44 UTC, 8 replies.
- [PR] MINOR: Close MockitoStatic in try-with-resource [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/29 14:21:07 UTC, 2 replies.
- [PR] KAFKA-9545: Fix IllegalStateException in updateLags [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2023/12/29 14:31:41 UTC, 1 replies.
- [PR] MINOR: move setReadOnly to Headers. [kafka] - posted by "LiangliangSui (via GitHub)" <gi...@apache.org> on 2023/12/29 15:02:50 UTC, 1 replies.
- [PR] fix typo. [kafka] - posted by "LiangliangSui (via GitHub)" <gi...@apache.org> on 2023/12/29 15:07:56 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16062) Upgrade mockito to 5.8.0 - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 15:50:00 UTC, 1 replies.
- Re: [PR] MINOR: fix typo. [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/29 15:51:15 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16065) Fix leak in DelayedOperationTest - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/29 17:34:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16068) Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin scanning errors - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/29 18:36:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16068) Use TestPlugins in ConnectorValidationIntegrationTest to silence plugin scanning errors - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/29 18:36:00 UTC, 0 replies.
- [PR] WIP: add parallelism to Jenkins tests [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/29 19:04:52 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27 - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2023/12/29 19:32:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16069) Source Tasks re-transform records after Retriable exceptions - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2023/12/29 23:27:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16070) Extract the setReadOnly method into Headers - posted by "Lighting Sui (Jira)" <ji...@apache.org> on 2023/12/30 02:45:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16071) NPE in testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2023/12/30 07:06:00 UTC, 0 replies.
- [jira] (KAFKA-16063) Fix leaked ApplicationShutdownHooks in EndToEndAuthorizationTests - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/30 07:45:00 UTC, 0 replies.
- [PR] Fixing flaky Unit tests in GroupMetadataManagerTest [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2023/12/30 07:55:58 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16064) Improve ControllerApisTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2023/12/30 19:40:00 UTC, 1 replies.
- Re: [PR] KAFKA-16064: Improve ControllerApisTest [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/30 20:48:00 UTC, 3 replies.
- Re: [PR] KAFKA-15742: KRaft support in GroupCoordinatorIntegrationTest [kafka] - posted by "wernerdv (via GitHub)" <gi...@apache.org> on 2023/12/30 21:31:12 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15721) KRaft support in DeleteTopicsRequestWithDeletionDisabledTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2023/12/30 21:37:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27 - posted by "Anish Lukkireddy (Jira)" <ji...@apache.org> on 2023/12/30 23:31:00 UTC, 1 replies.
- [jira] [Comment Edited] (KAFKA-16063) Fix leaked ApplicationShutdownHooks in EndToEndAuthorizationTests - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2023/12/31 02:09:00 UTC, 1 replies.
- Re: [PR] KAFKA-14112: Expose replication-offset-lag Mirror metric [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2023/12/31 03:33:16 UTC, 0 replies.
- Re: [PR] MINOR: Fixing flaky test GroupMetadataManagerTest.testStaticMemberGetsBackAssignmentUponRejoin [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/31 11:47:17 UTC, 1 replies.
- Re: [PR] KAFKA-15816: Fix leaked sockets in trogdor tests [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2023/12/31 15:34:48 UTC, 0 replies.
- [jira] [Created] (KAFKA-16072) Create Mockito extension to detect thread leak - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/31 16:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16072) Create Mockito extension to detect thread leak - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2023/12/31 18:21:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16072) Create Junit 5 extension to detect thread leak - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/31 18:45:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16072) Create Junit 5 extension to detect thread leak - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2023/12/31 18:46:00 UTC, 0 replies.