jira@kafka.apache.org, 2024-01

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

- [jira] [Commented] (KAFKA-16063) Fix leaked ApplicationShutdownHooks in EndToEndAuthorizationTests - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/01 07:47:00 UTC, 4 replies.
- Re: [PR] KAFKA-15816: Fix leaked sockets in runtime tests [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/01/01 10:35:17 UTC, 1 replies.
- [jira] [Created] (KAFKA-16073) Tiered Storage Bug: Incorrect Handling of Offset Ranges During Segment Deletion - posted by "hzh0425 (Jira)" <ji...@apache.org> on 2024/01/01 14:31:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16073) Tiered Storage Bug: Kafka Tiered Storage Bug: Consumer Fetch Error Due to Delayed localLogStartOffset Update During Segment Deletion - posted by "hzh0425 (Jira)" <ji...@apache.org> on 2024/01/01 14:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16073) Kafka Tiered Storage Bug: Consumer Fetch Error Due to Delayed localLogStartOffset Update During Segment Deletion - posted by "hzh0425 (Jira)" <ji...@apache.org> on 2024/01/01 14:34:00 UTC, 2 replies.
- Re: [PR] KAFKA-14517:Implement regex subscriptions [kafka] - posted by "JimmyWang6 (via GitHub)" <gi...@apache.org> on 2024/01/01 15:03:30 UTC, 5 replies.
- [jira] [Updated] (KAFKA-16063) Fix leaked ApplicationShutdownHooks in EndToEndAuthorizationTests - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/01 17:22:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16072) Create Junit 5 extension to detect thread leak - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/01/01 21:13:00 UTC, 0 replies.
- [PR] KAFKA-16072: JUnit 5 extension to detect thread leak [kafka] - posted by "wernerdv (via GitHub)" <gi...@apache.org> on 2024/01/01 21:23:57 UTC, 15 replies.
- [jira] [Updated] (KAFKA-16055) Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/01 22:42:00 UTC, 1 replies.
- [PR] MINOR: avoid unnecessary UnsupportedOperationException [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/01 22:47:10 UTC, 3 replies.
- [PR] KAFKA-15853: Move KafkaConfig to server module [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/01 23:29:21 UTC, 6 replies.
- Re: [PR] KAFKA-14483 Move/Rewrite of LocalLog to storage module. [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/01/02 04:35:51 UTC, 25 replies.
- [jira] [Commented] (KAFKA-16073) Kafka Tiered Storage Bug: Consumer Fetch Error Due to Delayed localLogStartOffset Update During Segment Deletion - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/01/02 06:20:00 UTC, 10 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 2024/01/02 06:46:00 UTC, 0 replies.
- Re: [PR] KAFKA-14133: Migrate stateManager mock in StoreChangelogReaderTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/02 07:25:20 UTC, 2 replies.
- [PR] KAFKA-16063: Prevent memory leak by Disabling shutdownhook [kafka] - posted by "iit2009060 (via GitHub)" <gi...@apache.org> on 2024/01/02 07:39:51 UTC, 2 replies.
- Re: [PR] KAFKA-16059: Fix thread leak KafkaAPIsTest [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/02 09:29:46 UTC, 6 replies.
- Re: [PR] KAFKA-9545: Fix IllegalStateException in updateLags [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/02 10:10:05 UTC, 1 replies.
- Re: [PR] MINOR: Upgrade Zstd-jni to 1.5.5-11 [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/01/02 10:20:53 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16072) Create Junit 5 extension to detect thread leak - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/02 11:19:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16074) Fix thread leaks in ReplicaManagerTest - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/02 11:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16074) Fix thread leaks in ReplicaManagerTest - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/02 11:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-14822: Allow restricting File and Directory ConfigProviders to specific paths [kafka] - posted by "tinaselenge (via GitHub)" <gi...@apache.org> on 2024/01/02 11:28:54 UTC, 23 replies.
- [PR] KAFKA-14412: Decouple RocksDB access from CF [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/01/02 11:52:53 UTC, 6 replies.
- [PR] KAFKA-14133: Migrate activeStateManager and standbyStateManager mocks in StoreChangelogReaderTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/02 13:01:10 UTC, 3 replies.
- [PR] MINOR: Improve code style about producer [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2024/01/02 13:15:12 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15206) Flaky test RemoteIndexCacheTest.testClose() - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2024/01/02 13:18:00 UTC, 0 replies.
- Re: [PR] KAFKA-15388: Handling remote segment read in case of log compaction [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/02 13:42:52 UTC, 30 replies.
- [PR] MINOR: Fix flaky test RemoteIndexCacheTest.testClose() [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2024/01/02 14:26:04 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15777) Configurable remote fetch bytes per partition from Consumer - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2024/01/02 14:28:00 UTC, 1 replies.
- Re: [PR] Bugfix: Prevent java.lang.UnsupportedOperationException. [kafka] - posted by "jamespfaulkner (via GitHub)" <gi...@apache.org> on 2024/01/02 14:51:29 UTC, 2 replies.
- [jira] [Commented] (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 2024/01/02 14:53:00 UTC, 2 replies.
- [PR] MINOR: Enable Gradle Remote Build Cache [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/01/02 14:59:12 UTC, 9 replies.
- [jira] [Updated] (KAFKA-15777) Configurable remote fetch bytes per partition from Consumer - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/01/02 15:08: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 2024/01/02 15:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-16046: also fix stores for outer join [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/02 16:26:10 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15816) Typos in tests leak network sockets - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/02 16:58:00 UTC, 1 replies.
- Re: [PR] KAFKA-15816: Fix leaked sockets in trogdor tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/02 17:22:38 UTC, 2 replies.
- Re: [PR] KAFKA-15215: docs for KIP-954 [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/01/02 18:42:17 UTC, 3 replies.
- [jira] [Commented] (KAFKA-16046) Stream Stream Joins fail after restoration with deserialization exceptions - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2024/01/02 19:17:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-16046) Stream Stream Joins fail after restoration with deserialization exceptions - posted by "Almog Gavra (Jira)" <ji...@apache.org> on 2024/01/02 19:17:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16051) Deadlock on connector initialization - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/02 19:36:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16051) Deadlock on connector initialization - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/02 19:38:00 UTC, 0 replies.
- Re: [PR] KAFKA-15556: Remove NetworkClientDelegate methods isUnavailable, maybeThrowAuthFailure, and tryConnect [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/01/02 20:26:15 UTC, 6 replies.
- [jira] [Created] (KAFKA-16075) TLS configuration not validated in KRaft controller-only nodes - posted by "Jakub Scholz (Jira)" <ji...@apache.org> on 2024/01/02 20:30:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16055) Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/01/02 20:54:00 UTC, 1 replies.
- Re: [PR] MINOR: Prototype: Measure CI slowness [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/02 21:01:06 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/01/02 21:11:00 UTC, 1 replies.
- Re: [PR] KAFKA-16025: Fix orphaned locks when rebalancing and store cleanup race on unassigned task directories [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/01/02 21:15:24 UTC, 4 replies.
- [jira] [Created] (KAFKA-16076) RestClient Interrupting the thread in case of InterruptedException - posted by "Mehrdad Karami (Jira)" <ji...@apache.org> on 2024/01/02 22:32:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16076) RestClient Interrupting the thread in case of InterruptedException - posted by "Mehrdad Karami (Jira)" <ji...@apache.org> on 2024/01/02 22:33:00 UTC, 0 replies.
- [PR] KAFKA-16076: Interrupting the currentThread fix [kafka] - posted by "metao1 (via GitHub)" <gi...@apache.org> on 2024/01/02 22:38:26 UTC, 1 replies.
- Re: [PR] KAFKA-15373: fix exception thrown in Admin#describeTopics for unknown ID [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/03 00:59:42 UTC, 1 replies.
- Re: [PR] MINOR: Increase parallelism for Jenkins [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/03 01:01:20 UTC, 2 replies.
- Re: [PR] KAFKA-15742: KRaft support in GroupCoordinatorIntegrationTest [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/03 01:07:50 UTC, 3 replies.
- [jira] [Assigned] (KAFKA-14510) Extend DescribeConfigs API to support group configs - posted by "Jimmy Wang (Jira)" <ji...@apache.org> on 2024/01/03 02:49:00 UTC, 0 replies.
- Re: [PR] [MINOR] remove meaningless lines [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/03 03:33:13 UTC, 0 replies.
- [jira] [Resolved] (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 2024/01/03 05:03:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/03 05:17:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/03 05:18:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16070) Extract the setReadOnly method into Headers - posted by "johndoe (Jira)" <ji...@apache.org> on 2024/01/03 05:20:00 UTC, 0 replies.
- Re: [PR] KAFKA-15720: KRaft support in DeleteTopicTest [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2024/01/03 08:43:53 UTC, 9 replies.
- Re: [PR] KAFKA-15942: Implement ConsumerInterceptors in the async consumer [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/03 08:52:50 UTC, 42 replies.
- Re: [PR] KAFKA-15344: Commit leader epoch where possible [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/03 08:55:52 UTC, 0 replies.
- [PR] MINOR: Bump year to 2024 in NOTICE file [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/01/03 09:28:07 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-16046) Stream Stream Joins fail after restoration with deserialization exceptions - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/03 09:46:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16073) Kafka Tiered Storage Bug: Consumer Fetch Error Due to Delayed localLogStartOffset Update During Segment Deletion - posted by "hzh0425 (Jira)" <ji...@apache.org> on 2024/01/03 09:55:00 UTC, 3 replies.
- Re: [PR] KAFKA-16016: Add docker wrapper in core and remove docker utility script [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2024/01/03 11:22:57 UTC, 21 replies.
- Re: [PR] MINOR: Prevent java.lang.UnsupportedOperationException in MockAdminClient [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/01/03 11:33:05 UTC, 3 replies.
- Re: [PR] MINOR: Fix toString method of IsolationLevel [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/03 12:35:39 UTC, 3 replies.
- Re: [PR] KAFKA-16051: Fixed deadlock in StandaloneHerder [kafka] - posted by "developster (via GitHub)" <gi...@apache.org> on 2024/01/03 12:47:05 UTC, 8 replies.
- [jira] [Commented] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread? - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/03 12:57:00 UTC, 0 replies.
- [PR] KAFKA-14133: Migrate consumer mock in TaskManagerTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/03 15:13:07 UTC, 7 replies.
- [PR] KAFKA-16070: extract the setReadOnly method into Headers [kafka] - posted by "Joker-5 (via GitHub)" <gi...@apache.org> on 2024/01/03 15:16:50 UTC, 0 replies.
- [PR] Test2 [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2024/01/03 15:29:37 UTC, 2 replies.
- [PR] MINOR: Add reviewers GitHub action [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2024/01/03 15:43:14 UTC, 13 replies.
- [PR] KAFKA-14133: Migrate storeMetadata mock in StoreChangelogReaderTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/03 15:54:56 UTC, 6 replies.
- [jira] [Commented] (KAFKA-15147) Measure pending and outstanding Remote Segment operations - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/01/03 16:05:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-10875) offsetsForTimes returns null for some partitions when it shouldn't? - posted by "Hugo Abreu (Jira)" <ji...@apache.org> on 2024/01/03 16:15:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-10875) offsetsForTimes returns null for some partitions when it shouldn't? - posted by "Hugo Abreu (Jira)" <ji...@apache.org> on 2024/01/03 16:16:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15742) KRaft support in GroupCoordinatorIntegrationTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/01/03 16:54:00 UTC, 0 replies.
- Re: [PR] KAFKA-16070: move setReadOnly to Headers [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/01/03 17:59:03 UTC, 0 replies.
- Re: [PR] KAFKA-16070: Extract the setReadOnly method into Headers [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/01/03 18:00:42 UTC, 1 replies.
- [jira] [Created] (KAFKA-16077) State updater fails to close task when input partitions are updated - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/03 18:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16077) State updater fails to close task when input partitions are updated - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/03 18:07:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16077) Streams fails to close task after restoration when input partitions are updated - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/03 18:08:00 UTC, 2 replies.
- [PR] KAFKA-16077: Streams fails to close task after restoration [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/03 18:11:23 UTC, 0 replies.
- [jira] [Created] (KAFKA-16078) InterBrokerProtocolVersion defaults to non-production MetadataVersion - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/03 18:51:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16078) InterBrokerProtocolVersion defaults to non-production MetadataVersion - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/03 19:21:00 UTC, 0 replies.
- [PR] KAFKA-16078 IBP defaults to latest production MetadataVersion [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/01/03 19:50:06 UTC, 5 replies.
- [PR] MINOR: Move Raft io thread implementation to Java [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/01/03 19:51:01 UTC, 7 replies.
- [PR] MINOR: Fixed typos in docker readme documentation [kafka] - posted by "kumarlokesh (via GitHub)" <gi...@apache.org> on 2024/01/03 21:27:17 UTC, 1 replies.
- Re: [PR] KAFKA-15987: Refactor ReplicaManager code for transaction verification [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/01/03 22:41:50 UTC, 10 replies.
- [jira] [Closed] (KAFKA-10133) Cannot compress messages in destination cluster with MM2 - posted by "Steve Jacobs (Jira)" <ji...@apache.org> on 2024/01/03 23:02:00 UTC, 0 replies.
- Re: [PR] KAFKA-16067 Refactoring ConsumerGroupListing + add test [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/01/03 23:04:47 UTC, 4 replies.
- [jira] [Updated] (KAFKA-15467) Kafka broker returns offset out of range for topic/partitions on restart from unclean shutdown - posted by "Steve Jacobs (Jira)" <ji...@apache.org> on 2024/01/03 23:05:00 UTC, 1 replies.
- Re: [PR] KAFKA-16074: close leaking threads in replica manager tests [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/04 02:51:41 UTC, 6 replies.
- [PR] KAFKA-16055: Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders [kafka] - posted by "nuzayats (via GitHub)" <gi...@apache.org> on 2024/01/04 06:12:23 UTC, 0 replies.
- [jira] [Created] (KAFKA-16079) Fix leak in LocalLeaderEndPointTest/FinalizedFeatureChangeListenerTest/KafkaApisTest/ReplicaManagerConcurrencyTest - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/04 08:25:00 UTC, 0 replies.
- [PR] KAFKA-16079: fix threads leak threads in LocalLeaderEndPointTest and other tests [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/04 08:25:17 UTC, 6 replies.
- [PR] Test minor gh review action - this is a test PR, do not review [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2024/01/04 09:16:45 UTC, 0 replies.
- [PR] KAFKA-15721: KRaft support in DeleteTopicsRequestWithDeletionDisabledTest [kafka] - posted by "wernerdv (via GitHub)" <gi...@apache.org> on 2024/01/04 09:46:05 UTC, 4 replies.
- Re: [PR] KAFKA-14588 ConfigEntityName move to server-common [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/04 10:18:46 UTC, 8 replies.
- Re: [PR] MINOR: improve logging for state management [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/04 10:21:54 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16077) Streams fails to close task after restoration when input partitions are updated - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/04 10:56:00 UTC, 0 replies.
- Re: [PR] KAFKA-12399: Deprecate Log4J Appender [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/04 11:05:09 UTC, 0 replies.
- Re: [PR] KAFKA-16077: Streams with state updater fails to close task upon fencing [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/01/04 11:44:21 UTC, 6 replies.
- [jira] [Created] (KAFKA-16080) partiton not retention after execute ALTER_REPLICA_LOG_DIRS and LEADER_AND_ISR request at the same time - posted by "wangliucheng (Jira)" <ji...@apache.org> on 2024/01/04 11:54:00 UTC, 0 replies.
- [PR] KAFKA-14133: Migrate remaining mocks in StoreChangelogReaderTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/04 13:20:30 UTC, 3 replies.
- Re: [PR] KAFKA-15817: Avoid reconnecting to the same IP address (#14813) [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/01/04 13:39:45 UTC, 1 replies.
- [jira] [Created] (KAFKA-16081) Limit number of ssl connections in brokers - posted by "Jimmy Wang (Jira)" <ji...@apache.org> on 2024/01/04 13:55:00 UTC, 0 replies.
- [PR] KAFKA-16081 Limit number of ssl connections in brokers [kafka] - posted by "JimmyWang6 (via GitHub)" <gi...@apache.org> on 2024/01/04 13:59:15 UTC, 1 replies.
- [jira] [Created] (KAFKA-16082) JBOD: Possible dataloss when moving leader partition - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2024/01/04 14:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16082) JBOD: Possible dataloss when moving leader partition - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2024/01/04 14:45:00 UTC, 8 replies.
- [jira] [Commented] (KAFKA-16082) JBOD: Possible dataloss when moving leader partition - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/04 15:11:00 UTC, 3 replies.
- Re: [PR] KAFKA-16003: Always create the /config/topics ZNode even for topics w… [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/04 15:38:16 UTC, 4 replies.
- [PR] MINOR: Fixing shadow jar publish [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/01/04 16:03:31 UTC, 1 replies.
- Re: [PR] KAFKA-15062: Adding ppc64le build stage [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/04 16:07:34 UTC, 1 replies.
- [PR] MINOR: Small cleanups in Connect [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/04 16:36:34 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16081) Limit number of ssl connections in brokers - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/04 16:52:00 UTC, 0 replies.
- Re: [PR] MINOR: New year code clean up - misc [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/04 17:10:11 UTC, 3 replies.
- [jira] [Created] (KAFKA-16083) Exclude throttle time when expiring inflight requests on a connection - posted by "Adithya Chandra (Jira)" <ji...@apache.org> on 2024/01/04 17:20:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14404) Fix & update docs on client configs controlled by Streams - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/01/04 17:21:00 UTC, 1 replies.
- [PR] Quotav2handler [DRAFT] [kafka] - posted by "nickgarvey (via GitHub)" <gi...@apache.org> on 2024/01/04 18:38:06 UTC, 1 replies.
- [PR] KAFKA-16083: Exclude throttle time when expiring inflight requests on a connection [kafka] - posted by "ditac (via GitHub)" <gi...@apache.org> on 2024/01/04 19:28:01 UTC, 9 replies.
- [jira] [Created] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/04 19:40:00 UTC, 0 replies.
- [PR] MINOR: Add public documentation for metrics introduced in KIP-963 [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/04 19:57:12 UTC, 8 replies.
- Re: [PR] Minor: Add KIP-923 to upgrade-guide.html and dsl-api.html [kafka] - posted by "wcarlson5 (via GitHub)" <gi...@apache.org> on 2024/01/04 20:01:43 UTC, 3 replies.
- [jira] [Resolved] (KAFKA-16079) Fix leak in LocalLeaderEndPointTest/FinalizedFeatureChangeListenerTest/KafkaApisTest/ReplicaManagerConcurrencyTest - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/05 01:45:00 UTC, 0 replies.
- [PR] KAFKA-16059: close more kafkaApis instances [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/05 03:55:20 UTC, 9 replies.
- [jira] [Commented] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/05 04:49:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16060) Some questions about tiered storage capabilities - posted by "Jianbin Chen (Jira)" <ji...@apache.org> on 2024/01/05 08:04:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16085) remote copy lag bytes/segments metrics don't update all topic value - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/05 08:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16085) remote copy lag bytes/segments metrics don't update all topic value - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/05 08:20:00 UTC, 0 replies.
- [PR] KAFKA-16085: add all topic metrics [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/05 08:29:59 UTC, 3 replies.
- [jira] [Updated] (KAFKA-14133) Remaining EasyMock to Mockito tests - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/01/05 09:22:00 UTC, 0 replies.
- [PR] MINOR: Address occasional UnnecessaryStubbingException in StreamThreadTest [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/05 09:37:45 UTC, 5 replies.
- [jira] [Created] (KAFKA-16086) Kafka Streams has RocksDB native memory leak - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/05 09:45:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16086) Kafka Streams has RocksDB native memory leak - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/05 09:47:00 UTC, 0 replies.
- [PR] KAFKA-16086: Fix memory leak in RocksDBStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/01/05 09:47:08 UTC, 6 replies.
- [jira] [Assigned] (KAFKA-16086) Kafka Streams has RocksDB native memory leak - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/05 09:49:00 UTC, 0 replies.
- Re: [PR] MINOR: New year code cleanup - include final keyword [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/05 10:15:22 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16086) Kafka Streams has RocksDB native memory leak - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2024/01/05 10:45:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-16086) Kafka Streams has RocksDB native memory leak - posted by "Nicholas Telford (Jira)" <ji...@apache.org> on 2024/01/05 10:46:00 UTC, 1 replies.
- [PR] KAFKA-16082: Avoid resuming future replica if current replica is in the same directory [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/01/05 11:41:40 UTC, 7 replies.
- Re: [PR] KAFKA-16085: Add metric value consolidated for topics on a broker for tiered storage. [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/05 12:40:58 UTC, 29 replies.
- Re: [PR] MINOR: Add 3.6.1 to system tests [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/05 13:15:53 UTC, 0 replies.
- Re: [PR] MINOR: Add 3.5.2 and 3.6.1 to system tests [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/05 13:58:35 UTC, 3 replies.
- Re: [PR] KAFKA-15704: Update clientId and clientHost in MemberMetadata when static member is replaced. [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/01/05 15:42:02 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15922) Add MetadataVersion for JBOD - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2024/01/05 15:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15922) Add MetadataVersion for JBOD - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2024/01/05 15:43: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 2024/01/05 16:08:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-14404) Fix & update docs on client configs controlled by Streams - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/01/05 16:10:00 UTC, 0 replies.
- Re: [PR] MINOR: Enable kraft test in kafka.api and kafka.network [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/05 16:42:17 UTC, 3 replies.
- [PR] KAFKA-14412: Transactional StateStores [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/01/05 17:09:00 UTC, 10 replies.
- [jira] [Created] (KAFKA-16087) Sink connector dropping incorrect record when ErrantRecordReporter used asynchronously - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/05 21:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16087) Sink connector dropping incorrect record when ErrantRecordReporter used asynchronously - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/05 23:34:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16087) Tasks dropping incorrect records when errors.tolerance=all and errors reported asynchronously due to data race - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/05 23:38:00 UTC, 2 replies.
- Re: [PR] KAFKA-15468: Prevent transaction coordinator reloads on already loaded leaders [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/06 00:29:45 UTC, 1 replies.
- [PR] KAFKA-15468 [1/2]: Prevent transaction coordinator reloads on already loaded leaders [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/06 01:09:16 UTC, 16 replies.
- Re: [PR] Remove consumer rejoin to the group's synchronized lock [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/06 03:33:11 UTC, 0 replies.
- Re: [PR] KAFKA-15134:Enrich the prompt reason in CommitFailedException [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/06 03:33:22 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15682) Ensure internal remote log metadata topic does not expire its segments before deleting user-topic segments - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/06 04:37:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-13949) Connect /connectors endpoint should support querying the active topics and the task configs - posted by "Sudesh Wasnik (Jira)" <ji...@apache.org> on 2024/01/06 07:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-13949) Connect /connectors endpoint should support querying the active topics and the task configs - posted by "Sudesh Wasnik (Jira)" <ji...@apache.org> on 2024/01/06 07:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15717) KRaft support in LeaderEpochIntegrationTest - posted by "GyeongWon, Do (Jira)" <ji...@apache.org> on 2024/01/06 08:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16069) Source Tasks re-transform records after Retriable exceptions - posted by "Sudesh Wasnik (Jira)" <ji...@apache.org> on 2024/01/06 12:17:00 UTC, 0 replies.
- [PR] 16069 - prevent re-transform of source-records after retriable exceptions [kafka] - posted by "wasniksudesh (via GitHub)" <gi...@apache.org> on 2024/01/06 12:30:54 UTC, 0 replies.
- Re: [PR] KAFKA-16047: Leverage the fenceProducers timeout in the InitProducerId [kafka] - posted by "akaltsikis (via GitHub)" <gi...@apache.org> on 2024/01/06 12:33:33 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16084) Simplify and deduplicate StandaloneHerderTest mocking - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/06 16:52:00 UTC, 3 replies.
- Re: [PR] KAFKA-14683 Migrate #testStartPaused to Mockito [kafka] - posted by "hgeraldino (via GitHub)" <gi...@apache.org> on 2024/01/06 19:07:49 UTC, 15 replies.
- Re: [PR] KAFKA-14112: Expose replication-offset-lag Mirror metric [kafka] - posted by "elkkhan (via GitHub)" <gi...@apache.org> on 2024/01/07 01:36:19 UTC, 0 replies.
- [jira] [Created] (KAFKA-16088) Not reading active segments when RemoteFetch return Empty Records. - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/07 07:27:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16088) Not reading active segments when RemoteFetch return Empty Records. - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/07 07:29:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15876) Introduce Remote Storage Not Ready Exception - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/01/07 12:10:00 UTC, 0 replies.
- [PR] KAFKA-16073: [Tiered] Update localLogStartOffset before deleting segments in memory t… [kafka] - posted by "hzh0425 (via GitHub)" <gi...@apache.org> on 2024/01/07 15:49:47 UTC, 6 replies.
- Re: [PR] KAFKA-15560: Upgrade argparse4j to 0.9.0 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/08 03:33:11 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/08 04:11:00 UTC, 10 replies.
- [jira] [Commented] (KAFKA-13679) Superfluous node disconnected log messages - posted by "Pritam Kumar (Jira)" <ji...@apache.org> on 2024/01/08 07:45:00 UTC, 0 replies.
- Re: [PR] KAFKA-15417 flip joinSpuriousLookBackTimeMs and emit non-joined items [kafka] - posted by "VictorvandenHoven (via GitHub)" <gi...@apache.org> on 2024/01/08 08:47:54 UTC, 1 replies.
- [jira] [Created] (KAFKA-16089) Kafka Streams still leaking memory in 3.7 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/08 09:00:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16089) Kafka Streams still leaking memory in 3.7 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/08 09:02:00 UTC, 4 replies.
- Re: [PR] MINOR: Fix shadow jar publishing for the clients module [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/01/08 09:42:51 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16088) Not reading active segments when RemoteFetch return Empty Records. - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/08 10:42:00 UTC, 2 replies.
- [jira] [Created] (KAFKA-16090) Refactor call to storage tool from kafka docker wrapper - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2024/01/08 11:51:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16091) Pipeline to run docker build test on a PR - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2024/01/08 11:53:00 UTC, 0 replies.
- Re: [PR] KAFKA-14588 ZK configuration moved to ZkConfig [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/08 11:53:35 UTC, 1 replies.
- [PR] KAFKA-14505; [4/N] Wire transaction verification [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/08 12:47:16 UTC, 31 replies.
- Re: [PR] KAFKA-14588 Move DynamicConfig to server-commons [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/01/08 13:17:17 UTC, 8 replies.
- [PR] MINOR: remove classic group preparing rebalance sensor [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/01/08 14:16:55 UTC, 2 replies.
- Re: [PR] KAFKA-15747: KRaft support in DynamicConnectionQuotaTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/08 14:29:00 UTC, 8 replies.
- [jira] [Resolved] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 14:31:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15558) Determine if Timer should be used elsewhere in PrototypeAsyncConsumer.updateFetchPositions() - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/08 14:33:00 UTC, 1 replies.
- Re: [PR] KAFKA-15746: KRaft support in ControllerMutationQuotaTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/08 14:36:16 UTC, 0 replies.
- Re: [PR] KAFKA-15741: KRaft support in DescribeConsumerGroupTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/08 15:01:14 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-16016) Migrate utility scripts to kafka codebase - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2024/01/08 15:08:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15725) KRaft support in FetchRequestTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/08 15:17:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15832) Trigger client reconciliation based on manager poll - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 15:26:00 UTC, 9 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 2024/01/08 15:46:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15515) Remove duplicated integration tests for new consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 15:54:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15839) Review topic ID integration in consumer membershipManager - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 16:04:00 UTC, 0 replies.
- [PR] Draft: Revert RocksDB change and disable state updater [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/08 16:08:33 UTC, 1 replies.
- [jira] [Commented] (KAFKA-16054) Sudden 100% CPU on a broker - posted by "Oleksandr Shulgin (Jira)" <ji...@apache.org> on 2024/01/08 16:09:00 UTC, 0 replies.
- [PR] KAFKA-16089: Revert "KAFKA-14412: Better Rocks column family management" [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/08 16:14:35 UTC, 2 replies.
- [PR] Draft: disable state updater in 3.7 [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/08 16:17:57 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15839) Review topic ID integration in consumer reconciliation process - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 16:18:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15283) Add support for topic ID-related Consumer changes - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 16:21:00 UTC, 0 replies.
- Re: [PR] KAFKA-15719: KRaft support in OffsetsForLeaderEpochRequestTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/08 16:21:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15719) KRaft support in OffsetsForLeaderEpochRequestTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/08 16:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 16:28:00 UTC, 6 replies.
- [jira] [Updated] (KAFKA-15847) Allow to resolve client metadata for specific topics - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 16:58:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15847) Consider partial metadata requests for client reconciliation - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:00:00 UTC, 4 replies.
- [jira] [Updated] (KAFKA-16033) Review client retry logic of OffsetFetch and OffsetCommit responses - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:03:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-16032) Review client inconsistent error handling of OffsetFetch and OffsetCommit responses - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:03:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15538) Client support for java regex based subscription - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:10:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-15542) Release member assignments on errors - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:14:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15835) Group commit/callbacks triggering logic - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:16:00 UTC, 2 replies.
- Re: [PR] KAFKA-14589 ConsumerGroupCommand options and case classes rewritten [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/01/08 17:17:26 UTC, 25 replies.
- [jira] [Updated] (KAFKA-15846) Review consumer leave group request best effort and response handling - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:19:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15846) Review consumer leave group request best effort - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:19:00 UTC, 0 replies.
- [PR] KAFKA-7957: Enable testMetricsReporterUpdate [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/08 17:20:32 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15954) Review minimal effort approach on consumer last heartbeat on unsubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:22:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15846) Review consumer leave group request best effort and response handling - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:22:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/08 17:23:00 UTC, 5 replies.
- [jira] [Created] (KAFKA-16092) Queues for Kafka - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/08 17:26:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16092) Queues for Kafka - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/08 18:01:00 UTC, 1 replies.
- Re: [PR] MINOR: Update documentation.html with the 3.7 release [kafka] - posted by "stanislavkozlovski (via GitHub)" <gi...@apache.org> on 2024/01/08 18:19:51 UTC, 0 replies.
- [PR] KAFKA-15807: Added support for compression of metrics (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/01/08 18:35:19 UTC, 29 replies.
- [jira] [Created] (KAFKA-16093) Spurious warnings logged to stderr about empty path annotations and providers not implementing provider interfaces - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/08 18:49:00 UTC, 0 replies.
- [PR] KAFKA-16093: Fix spurious REST-related warnings on Connect startup [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/08 18:50:42 UTC, 17 replies.
- [PR] KAFKA-15462: Add Group Type Filter for List Group to the Admin Client [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/01/08 19:08:20 UTC, 26 replies.
- [jira] [Assigned] (KAFKA-15744) KRaft support in CustomQuotaCallbackTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/01/08 20:07:00 UTC, 2 replies.
- [PR] KAFKA-15594: Add version 3.6 to Kafka Streams system tests [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/08 21:13:55 UTC, 10 replies.
- [jira] [Assigned] (KAFKA-15724) KRaft support in OffsetFetchRequestTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/01/08 21:14:00 UTC, 2 replies.
- Re: [PR] MINOR: set test global timeout as 10 mins [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/08 21:15:38 UTC, 1 replies.
- [PR] KAFKA-15460: Add group type filter to List Groups API [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/01/08 21:19:41 UTC, 50 replies.
- Re: [PR] KAFKA-15756: [2/2] Migrate existing integration tests to run old protocol in new coordinator [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/01/08 22:00:44 UTC, 0 replies.
- [jira] [Created] (KAFKA-16094) 3.7 brokers must be able to register with 3.6 and earlier controllers - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/08 22:33:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16094) BrokerRegistrationRequest.logDirs field must be ignorable - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/08 22:34:00 UTC, 0 replies.
- [PR] KAFKA-16094: BrokerRegistrationRequest.logDirs field must be ignorable [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/01/08 22:44:32 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-15462) Add group type filter to the admin client - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/01/08 22:48:00 UTC, 0 replies.
- Re: [PR] KAFKA-15460: Add group type filter to the List Groups API [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/01/08 22:49:04 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/01/08 22:51:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16025) Streams StateDirectory has orphaned locks after rebalancing, blocking future rebalancing - posted by "A. Sophie Blee-Goldman (Jira)" <ji...@apache.org> on 2024/01/08 22:52:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/01/08 22:56:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/01/08 22:58:00 UTC, 0 replies.
- [PR] KAFKA-16087: Avoid data race which drops wrong record when errors.tolerance=all and asynchronous error occurs [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/08 23:54:19 UTC, 29 replies.
- [jira] [Updated] (KAFKA-15282) Implement client support for KIP-848 client-side assignors - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:08: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 2024/01/09 00:08:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15279) Implement client support for KIP-848 client-side assigner RPCs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:08:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15173) Consumer event queues should be bounded - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:08:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15321) Document consumer group member state machine - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:23:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15320) Document event queueing patterns - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:23:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-16024) SaslPlaintextConsumerTest#testCoordinatorFailover is flaky - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:46:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15615) Improve handling of fetching during metadata updates - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 00:46:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 03:13:00 UTC, 2 replies.
- [jira] [Updated] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 03:17:00 UTC, 3 replies.
- Re: [PR] KAFKA-15567 Fix benchmark code to work [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/09 03:33:07 UTC, 0 replies.
- Re: [PR] KAFKA-15452: Access SslPrincipalMapper and kerberosShortNamer in Custom KafkaPrincipalBuilder(KIP-982) [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/09 03:33:10 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16037) Upgrade existing system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 03:40:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15872) Investigate autocommit retry logic - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/09 04:52:00 UTC, 1 replies.
- [jira] (KAFKA-15872) Investigate autocommit retry logic - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/09 04:52:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15250) DefaultBackgroundThread is running tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/09 04:55:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15250) DefaultBackgroundThread is running tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/09 04:55:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15738) KRaft support in ConsumerWithLegacyMessageFormatIntegrationTest - posted by "Abhinav Dixit (Jira)" <ji...@apache.org> on 2024/01/09 06:59:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15737) KRaft support in ConsumerBounceTest - posted by "Kaushik Raina (Jira)" <ji...@apache.org> on 2024/01/09 07:14:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16096) Drop broker and tools support for Java 11 in Kafka 4.0 (deprecate in 3.7) (KIP-1013) - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/09 08:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15735) KRaft support in SaslMultiMechanismConsumerTest - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2024/01/09 08:11:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16096) Drop broker and tools support for Java 11 in Kafka 4.0 (deprecate in 3.7) (KIP-1013) - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/09 08:11:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16096) Drop broker and tools support for Java 11 in Kafka 4.0 (deprecate in 3.7) (KIP-1013) - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/09 08:12:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16097) State updater removes task without pending action in EOSv2 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 08:23:00 UTC, 0 replies.
- Re: [PR] KAFKA-16097: Disable state updater in 3.7 [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/09 08:24:35 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16097) State updater removes task without pending action in EOSv2 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 08:29:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16097) State updater removes task without pending action in EOSv2 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 08:29:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16089) Kafka Streams still leaking memory - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 08:31:00 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16089) Kafka Streams still leaking memory - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 08:32:00 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-15736) KRaft support in PlaintextConsumerTest - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2024/01/09 08:49:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15734) KRaft support in BaseConsumerTest - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2024/01/09 08:51:00 UTC, 0 replies.
- [PR] KAFKA-14505; [5/N] Add `UNSTABLE_OFFSET_COMMIT` error support [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/09 08:51:38 UTC, 22 replies.
- [jira] [Created] (KAFKA-16098) State updater may attempt to resume a task that is not assigned anymore - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 09:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16098) State updater may attempt to resume a task that is not assigned anymore - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 09:12:00 UTC, 0 replies.
- [PR] [KAFKA-15735] Adding KRaft test [kafka] - posted by "sjhajharia (via GitHub)" <gi...@apache.org> on 2024/01/09 09:41:13 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15749) KRaft support in KafkaMetricReporterClusterIdTest - posted by "Chirag Wadhwa (Jira)" <ji...@apache.org> on 2024/01/09 10:03:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15553) Review committed offset refresh logic - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/09 10:21:00 UTC, 0 replies.
- [PR] MINOR: bump dev version for system tests to 3.8 [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/09 10:22:03 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15727) KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest - posted by "Sanskar Jhajharia (Jira)" <ji...@apache.org> on 2024/01/09 10:34:00 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-15726) KRaft support in ProduceRequestTest - posted by "Manikumar (Jira)" <ji...@apache.org> on 2024/01/09 10:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14519) Add metrics to the new coordinator - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/09 11:01:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16099) Handle timeouts for AsyncKafkaConsumer.commitSync - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/09 11:07:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16100) Consistent handling of timeouts and responses for new consumer ApplicationEvents - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/09 11:13:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16101) Kafka cluster unavailable during KRaft migration rollback procedure - posted by "Paolo Patierno (Jira)" <ji...@apache.org> on 2024/01/09 11:51:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16101) Kafka cluster unavailable during KRaft migration rollback procedure - posted by "Paolo Patierno (Jira)" <ji...@apache.org> on 2024/01/09 11:55:00 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2024/01/09 12:11:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14508) Add ConsumerGroupInstallAssignment API - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/09 12:24:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-15538) Client support for java regex based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/09 12:25:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15538) Client support for java regex based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/09 12:26:00 UTC, 10 replies.
- [jira] [Commented] (KAFKA-14507) Add ConsumerGroupPrepareAssignment API - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/09 12:29:00 UTC, 2 replies.
- [jira] [Assigned] (KAFKA-16069) Source Tasks re-transform records after Retriable exceptions - posted by "Sudesh Wasnik (Jira)" <ji...@apache.org> on 2024/01/09 13:35:00 UTC, 0 replies.
- Re: [PR] MINOR: log new coordinator partition load schedule time [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/09 13:42:55 UTC, 5 replies.
- [jira] [Assigned] (KAFKA-14508) Add ConsumerGroupInstallAssignment API - posted by "Alexander Aghili (Jira)" <ji...@apache.org> on 2024/01/09 13:46:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15870) Move new group coordinator metrics from Yammer to Metrics - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/09 14:02:00 UTC, 0 replies.
- Re: [PR] KAFKA-14511: extend AlterIncrementalConfigs API to support group config [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/01/09 14:21:07 UTC, 9 replies.
- Re: [PR] KAFKA-4759 Add support for IPv4 and IPv6 ranges in AclAuthorizer [kafka] - posted by "EshginGuluzade (via GitHub)" <gi...@apache.org> on 2024/01/09 14:22:35 UTC, 4 replies.
- [jira] [Resolved] (KAFKA-15741) KRaft support in DescribeConsumerGroupTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/09 14:30:00 UTC, 0 replies.
- [PR] KAFKA-15853: Move KafkaConfig.Defaults to server module [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/09 14:37:25 UTC, 47 replies.
- [jira] [Assigned] (KAFKA-14949) Add Streams upgrade tests from AK 3.4 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/09 14:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-14949) Add Streams upgrade tests from AK 3.4 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/09 14:42:00 UTC, 0 replies.
- [jira] [Comment Edited] (KAFKA-15538) Client support for java regex based subscription - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 14:44:00 UTC, 5 replies.
- [jira] [Resolved] (KAFKA-15982) Move GenericGroup state metrics to `GroupCoordinatorMetricsShard` - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/09 14:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-14304) ZooKeeper to KRaft Migration - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/09 15:07:00 UTC, 1 replies.
- Re: [PR] KAFKA-15988: Reuse embedded clusters across test cases in Connect OffsetsApiIntegrationTest suite [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/09 15:31:28 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15268) Consider replacing Subscription Metadata by a hash - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/09 15:41:00 UTC, 0 replies.
- Re: [PR] KAFKA-13922: Adjustments for jacoco, coverage reporting [kafka] - posted by "viktorsomogyi (via GitHub)" <gi...@apache.org> on 2024/01/09 15:45:45 UTC, 6 replies.
- [jira] [Updated] (KAFKA-16103) Review client logic for triggering offset commit callbacks - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 15:49:00 UTC, 1 replies.
- [jira] [Created] (KAFKA-16102) about DynamicListenerConfig, the dynamic modification of the listener's port or IP does not take effect. - posted by "Jialun Peng (Jira)" <ji...@apache.org> on 2024/01/09 15:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16103) Review client logic for triggering offset commit callbacks - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 15:49:00 UTC, 0 replies.
- [jira] [Created] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/09 15:52:00 UTC, 0 replies.
- [PR] KAFKA-15853: Move ClientQuotaManagerConfig outside of core [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/09 15:57:53 UTC, 19 replies.
- [PR] KAFKA-15853: Move ReplicationQuotaManagerConfig to server module [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/09 16:04:29 UTC, 8 replies.
- [PR] KAFKA-15853: Move OffsetConfig to group-coordinator module [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/09 16:21:33 UTC, 4 replies.
- [PR] [Kafka-14404] fix overlap of docs sections & describe additional parameters [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2024/01/09 17:24:26 UTC, 0 replies.
- [jira] [Updated] (KAFKA-14404) Fix & update docs on client configs controlled by Streams - posted by "Ayoub Omari (Jira)" <ji...@apache.org> on 2024/01/09 17:32:00 UTC, 2 replies.
- [PR] KAFKA-16097: Add suspended tasks back to the state updater when reassigned [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/09 17:49:19 UTC, 1 replies.
- [jira] [Updated] (KAFKA-15284) Implement ConsumerGroupProtocolVersionResolver to determine consumer group protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 17:50:00 UTC, 1 replies.
- [PR] KAFKA-15853: Move PasswordEncoder to server module [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/09 18:09:46 UTC, 2 replies.
- [PR] Reassignment fix [kafka] - posted by "AnatolyPopov (via GitHub)" <gi...@apache.org> on 2024/01/09 18:14:23 UTC, 0 replies.
- [jira] [Created] (KAFKA-16105) Reassignment of tiered topics is failing due to RemoteStorageException - posted by "Anatolii Popov (Jira)" <ji...@apache.org> on 2024/01/09 18:23:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16105) Reassignment of tiered topics is failing due to RemoteStorageException - posted by "Anatolii Popov (Jira)" <ji...@apache.org> on 2024/01/09 18:24:00 UTC, 0 replies.
- [PR] KAFKA-15853: Move ProcessRole to server module [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/09 18:24:57 UTC, 2 replies.
- [jira] [Resolved] (KAFKA-16099) Handle timeouts for AsyncKafkaConsumer.commitSync - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 18:52:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-15588) Purge the unsent offset commits/fetches when the member is fenced/failed - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 18:59:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-15475) Timeout request might retry forever even if the user API times out in PrototypeAsyncConsumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 19:00:00 UTC, 4 replies.
- Re: [PR] KAFKA-15585: Add DescribeTopics API server side support [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/01/09 19:12:46 UTC, 35 replies.
- [jira] [Commented] (KAFKA-15941) Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 19:27:00 UTC, 0 replies.
- [jira] [Closed] (KAFKA-15941) Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 19:28:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15941) Flaky test: shouldRestoreNullRecord() – org.apache.kafka.streams.integration.RestoreIntegrationTest - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/09 19:28:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15250) DefaultBackgroundThread is running tight loop - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 19:40:00 UTC, 1 replies.
- [jira] [Reopened] (KAFKA-15250) DefaultBackgroundThread is running tight loop - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 19:40:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15557) Investigate FetcherTest's/FetchRequestManager's duplicate metadata update in assignFromUserNoId - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 19:43:00 UTC, 1 replies.
- [jira] [Updated] (KAFKA-16100) Consistent handling of timeouts and responses for new consumer ApplicationEvents - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 19:46:00 UTC, 5 replies.
- [jira] [Updated] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/09 19:46:00 UTC, 4 replies.
- [jira] [Created] (KAFKA-16106) group size counters do not reflect the actual sizes when operations fail - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/01/09 19:54:00 UTC, 0 replies.
- [PR] KAFKA-15853: Move AuthorizerUtils and its dependencies to server module [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/09 20:24:16 UTC, 5 replies.
- [jira] [Comment Edited] (KAFKA-16082) JBOD: Possible dataloss when moving leader partition - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2024/01/09 20:50:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15455) Add support for OffsetCommit version 9 in consumer - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 21:24:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15872) Investigate autocommit retry logic - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 21:35:00 UTC, 0 replies.
- Re: [PR] Metadata schema checker [kafka] - posted by "mannoopj (via GitHub)" <gi...@apache.org> on 2024/01/09 21:35:36 UTC, 8 replies.
- [jira] [Updated] (KAFKA-16004) Review new consumer inflight offset commit logic - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 21:36:00 UTC, 3 replies.
- [jira] [Updated] (KAFKA-15553) Review consumer positions update using committed offset - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 21:39:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-15553) Review consumer positions update - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 21:39:00 UTC, 1 replies.
- [jira] [Resolved] (KAFKA-15967) Fix revocation in reconcilation logic - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 21:41:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15946) AsyncKafkaConsumer should retry commits on the application thread instead of auto-retry - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/09 21:44:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16094) BrokerRegistrationRequest.logDirs field must be ignorable - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/10 00:06:00 UTC, 0 replies.
- Re: [PR] KAFKA-15181: Improvements for TopicBaseRemoteLogMetadataManager [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/01/10 00:16:28 UTC, 7 replies.
- Re: [PR] KAFKA-14546 - Support Partitioner fallback to default [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/10 03:33:17 UTC, 6 replies.
- [jira] [Commented] (KAFKA-16071) NPE in testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - posted by "Owen C.H. Leung (Jira)" <ji...@apache.org> on 2024/01/10 06:43:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-15735) KRaft support in SaslMultiMechanismConsumerTest - posted by "Manikumar (Jira)" <ji...@apache.org> on 2024/01/10 07:19:00 UTC, 0 replies.
- [jira] [Updated] (KAFKA-16102) about DynamicListenerConfig, the dynamic modification of the listener's port or IP does not take effect. - posted by "Jialun Peng (Jira)" <ji...@apache.org> on 2024/01/10 07:28:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16090) Refactor call to storage tool from kafka docker wrapper - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/10 07:55:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-16101) Kafka cluster unavailable during KRaft migration rollback procedure - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/10 08:32:00 UTC, 1 replies.
- [jira] [Commented] (KAFKA-15752) KRaft support in SaslSslAdminIntegrationTest - posted by "Zihao Lin (Jira)" <ji...@apache.org> on 2024/01/10 08:39:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16098) State updater may attempt to resume a task that is not assigned anymore - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/01/10 08:57:00 UTC, 0 replies.
- [jira] [Commented] (KAFKA-9545) Flaky Test `RegexSourceIntegrationTest.testRegexMatchesTopicsAWhenDeleted` - posted by "Ashwin Pankaj (Jira)" <ji...@apache.org> on 2024/01/10 12:24:00 UTC, 1 replies.
- [PR] KAFKA-16098: Verify pending recycle action when standby is re-assigned [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/01/10 12:31:51 UTC, 1 replies.
- [jira] [Assigned] (KAFKA-15743) KRaft support in ReplicationQuotasTest - posted by "Dmitry Werner (Jira)" <ji...@apache.org> on 2024/01/10 12:54:00 UTC, 0 replies.
- [jira] [Resolved] (KAFKA-16097) State updater removes task without pending action in EOSv2 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/10 13:10:00 UTC, 0 replies.
- [jira] [Assigned] (KAFKA-16097) State updater removes task without pending action in EOSv2 - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/10 13:10:00 UTC, 0 replies.
- [PR] doc fix: use instead of backticks [kafka]

 - posted by "imba-tjd (via GitHub)" <gi...@apache.org> on 2024/01/10 13:55:06 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16093) Spurious warnings logged to stderr about empty path annotations and providers not implementing provider interfaces - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/10 14:17:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16093) Spurious warnings logged to stderr about empty path annotations and providers not implementing provider interfaces - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/10 14:18:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16052) OOM in Kafka test suite - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/10 14:21:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssgined completes - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/10 14:24:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16108) Backport fix for KAFKA-16093 to 3.7 - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/10 14:25:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16052) OOM in Kafka test suite - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/10 14:28:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssigned completes - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/10 14:29:00 UTC, 2 replies.

- [jira] [Resolved] (KAFKA-15866) Refactor OffsetFetchRequestState Error handling to be more consistent with OffsetCommitRequestState - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/10 14:51:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15839) Review topic ID integration in consumer subscription - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/10 14:54:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-15839) Topic ID integration in consumer subscription state - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/10 15:03:00 UTC, 3 replies.

- [jira] [Resolved] (KAFKA-15747) KRaft support in DynamicConnectionQuotaTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/10 16:49:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16098) State updater may attempt to resume a task that is not assigned anymore - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/01/10 17:01:00 UTC, 0 replies.

- [PR] MINOR: fix custom retry backoff in new group coordinator [kafka] - posted by "jeffkbkim (via GitHub)" <gi...@apache.org> on 2024/01/10 18:00:06 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16106) group size counters do not reflect the actual sizes when operations fail - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/01/10 18:11:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16109) Ensure system tests cover the "simple consumer + commit" use case - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/10 19:04:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16110) Implement consumer performance tests - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/10 19:05:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16111) Implement tests for tricky rebalance callbacks scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/10 19:06:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16112) Review JMX metrics in Async Consumer and determine the missing ones - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/10 19:08:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16110) Implement consumer performance tests - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/10 19:35:00 UTC, 1 replies.

- Re: [PR] KAFKA-15351: Ensure log-start-offset not updated to local-log-start-offset when remote storage enabled [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/01/10 21:39:49 UTC, 1 replies.

- [jira] [Created] (KAFKA-16113) AsyncKafkaConsumer: Add missing offset commit metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/11 00:34:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16113) AsyncKafkaConsumer: Add missing offset commit metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/11 00:34:00 UTC, 4 replies.

- Re: [PR] MINOR: Upgrade Gradle wrapper to version 8.4 [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/11 03:33:13 UTC, 0 replies.

- [jira] [Created] (KAFKA-16114) Fix partiton not retention after cancel alter intra broker log dir task - posted by "wangliucheng (Jira)" <ji...@apache.org> on 2024/01/11 05:55:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16114) Fix partiton not retention after cancel alter intra broker log dir task - posted by "wangliucheng (Jira)" <ji...@apache.org> on 2024/01/11 05:57:00 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-15538) Client support for java regex based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/11 06:44:00 UTC, 1 replies.

- [jira] [Reopened] (KAFKA-15538) Client support for java regex based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/11 06:55:00 UTC, 1 replies.

- [PR] KAFKA-15738: Adding KRaft support in ConsumerWithLegacyMessageFormatIntegrationTest [kafka] - posted by "adixitconfluent (via GitHub)" <gi...@apache.org> on 2024/01/11 08:21:24 UTC, 2 replies.

- [PR] KAFKA-16114:Fix partiton not retention after cancel alter intra broke… [kafka] - posted by "Albedooooooo (via GitHub)" <gi...@apache.org> on 2024/01/11 09:24:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15371) MetadataShell is stuck when bootstrapping - posted by "Oleg Opolev (Jira)" <ji...@apache.org> on 2024/01/11 09:25:00 UTC, 0 replies.

- [PR] MINOR: Disalow using a group id with only whitespaces in the new consumer group protocol [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/11 10:09:07 UTC, 3 replies.

- Re: [PR] KAFKA-14995: Automate asf.yaml collaborators refresh [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/11 10:41:37 UTC, 0 replies.

- [PR] KAFKA-16089: Fix memory leak in RocksDBStore [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/01/11 11:21:46 UTC, 2 replies.

- [PR] KAFKA-15751: KRaft support in BaseAdminIntegrationTest [kafka] - posted by "tinaselenge (via GitHub)" <gi...@apache.org> on 2024/01/11 11:31:01 UTC, 2 replies.

- [jira] [Assigned] (KAFKA-15747) KRaft support in DynamicConnectionQuotaTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/11 11:40:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16101) Kafka cluster unavailable during KRaft migration rollback procedure - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/11 12:13:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16089) Kafka Streams still leaking memory - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/11 12:27:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16105) Reassignment of tiered topics is failing due to RemoteStorageException - posted by "Anatolii Popov (Jira)" <ji...@apache.org> on 2024/01/11 12:57:00 UTC, 1 replies.

- [PR] KAFKA-14505; [6/N] Avoid recheduling callback in request thread [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/11 13:08:55 UTC, 20 replies.

- Re: [PR] KAFKA-15876: Introduce RemoteStorageNotReadyException retryable error [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/01/11 13:09:09 UTC, 5 replies.

- Re: [PR] [Kafka-14404] fix overlap of streams-config sections & describe additional parameters [kafka] - posted by "AyoubOm (via GitHub)" <gi...@apache.org> on 2024/01/11 14:14:00 UTC, 12 replies.

- [PR] KAFKA-16017: Checkpoint restored offsets instead of written offsets [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/01/11 14:28:46 UTC, 1 replies.

- [jira] [Comment Edited] (KAFKA-15147) Measure pending and outstanding Remote Segment operations - posted by "Francois Visconte (Jira)" <ji...@apache.org> on 2024/01/11 15:29:00 UTC, 2 replies.

- [PR] MINOR: Change Connect integration StopStartLatch::await to throw TimeoutException on timeout [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/11 16:42:19 UTC, 2 replies.

- [PR] MINOR: Add isRemoteLogEnabled parameter to the Log Loader Javadoc. [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2024/01/11 16:57:36 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invoke and verify the consumer callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:04:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:19:00 UTC, 5 replies.

- [jira] [Assigned] (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 2024/01/11 18:35:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15283) Client support for OffsetFetch and OffsetCommit with topic ID - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:35:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16110) Implement consumer performance tests - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:47:00 UTC, 0 replies.

- [jira] [Assigned] (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 2024/01/11 18:48:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15551) Evaluate conditions for short circuiting consumer API calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:52:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15639) Investigate ConsumerNetworkThreadTest's testResetPositionsProcessFailureIsIgnored - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:53:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15638) Investigate ConsumerNetworkThreadTest's testPollResultTimer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:53:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:54:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15692) New integration tests to ensure full coverage - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:54:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15691) Add new system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:54:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15843) Review consumer onPartitionsAssigned called with empty partitions - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:55:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15847) Consider partial metadata requests for client reconciliation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:55:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16001) Migrate ConsumerNetworkThreadTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:58:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15993) Enable max poll integration tests that depend on callback invocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:58:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16004) Review new consumer inflight offset commit logic - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:58:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15999) Migrate HeartbeatRequestManagerTest away from ConsumerTestBuilder - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:58:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16100) Consistent handling of timeouts and responses for new consumer ApplicationEvents - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:59:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:59:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:59:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:59:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16019) Some of the tests in PlaintextConsumer can't seem to deterministically invoke and verify the consumer callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:59:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 18:59:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssigned completes - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 19:00:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 19:00:00 UTC, 0 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 2024/01/11 19:12:00 UTC, 2 replies.

- [PR] KAFKA-15575: Begin enforcing 'tasks.max' property for connectors [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/11 19:20:07 UTC, 16 replies.

- [jira] [Created] (KAFKA-16115) AsyncKafkaConsumer: Add missing heartbeat metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/11 21:35:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16115) AsyncKafkaConsumer: Add missing heartbeat metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/11 21:36:00 UTC, 4 replies.

- [jira] [Created] (KAFKA-16116) AsyncKafkaConsumer: Add missing rebalance metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/11 21:37:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16116) AsyncKafkaConsumer: Add missing rebalance metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/11 21:37:00 UTC, 5 replies.

- [jira] [Updated] (KAFKA-16022) AsyncKafkaConsumer sometimes complains “No current assignment for partition {}” - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/11 22:47:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16117) Add Integration test for checking if the correct assignor is chosen - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/01/11 22:53:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/01/11 22:54:00 UTC, 2 replies.

- Re: [PR] KAFKA-15760: Disable flaky test testTaskRequestWithOldStartMsGetsUpdated [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 01:13:29 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-15760) org.apache.kafka.trogdor.coordinator.CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated is flaky - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/12 01:18:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-8115) Flaky Test CoordinatorTest#testTaskRequestWithOldStartMsGetsUpdated - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/12 01:20:00 UTC, 0 replies.

- Re: [PR] MINOR: Log a warning when connectors generate greater than tasks.max task configs [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 01:21:14 UTC, 2 replies.

- Re: [PR] MINOR: Add test case for follower fetch [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/12 03:33:22 UTC, 3 replies.

- Re: [PR] MINOR: Optimization of equals methods on implementations of Commands.Handler in shell.command package  [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/12 03:33:27 UTC, 0 replies.

- Re: [PR] MINOR: Enable kraft test in kafka.api [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2024/01/12 03:50:14 UTC, 0 replies.

- Re: [PR] MINOR: Add isRemoteLogEnabled parameter to the Log Loader Javadoc [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/12 03:54:02 UTC, 2 replies.

- [jira] (KAFKA-15561) Client support for new SubscriptionPattern based subscription - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/12 05:04:00 UTC, 0 replies.

- [PR] [KAFKA-15749] Adding support for Kraft in test testClusterIdPresent [kafka] - posted by "chirag-wadhwa5 (via GitHub)" <gi...@apache.org> on 2024/01/12 06:27:00 UTC, 2 replies.

- [jira] [Resolved] (KAFKA-15738) KRaft support in ConsumerWithLegacyMessageFormatIntegrationTest - posted by "Manikumar (Jira)" <ji...@apache.org> on 2024/01/12 08:12:00 UTC, 0 replies.

- Re: [PR] KAFKA-15740: KRaft support in DeleteOffsetsConsumerGroupCommandIntegrationTest [kafka] - posted by "linzihao1999 (via GitHub)" <gi...@apache.org> on 2024/01/12 08:23:49 UTC, 1 replies.

- Re: [PR] MINOR: Doc fix: use  instead of backticks [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/12 08:48:50 UTC, 0 replies.

- Re: [PR] improve TopicCommandIntegrationTest to be less flaky [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/12 09:09:22 UTC, 7 replies.

- [jira] [Created] (KAFKA-16118) Coordinator unloading fails when replica is deleted - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/12 09:44:00 UTC, 0 replies.

- [PR] KAFKA-16118; Coordinator unloading fails when replica is deleted [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/12 10:12:05 UTC, 10 replies.

- Re: [PR] KAFKA-15750: KRaft support in KafkaMetricReporterExceptionHandlingTest [kafka] - posted by "linzihao1999 (via GitHub)" <gi...@apache.org> on 2024/01/12 10:34:49 UTC, 1 replies.

- [jira] [Created] (KAFKA-16119) kraft_upgrade_test system test is broken - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/12 13:56:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16119) kraft_upgrade_test system test is broken - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/12 14:54:00 UTC, 0 replies.

- [PR] KAFKA-14505-7; [7/7] Always materialize the most recent committed offset [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/12 16:53:04 UTC, 0 replies.

- [jira] [Created] (KAFKA-16120) Partition reassignments in ZK migration dual write leaves stray partitions - posted by "David Mao (Jira)" <ji...@apache.org> on 2024/01/12 17:12:00 UTC, 0 replies.

- [PR] KAFKA-16120: Handle removed replicas during KRaft migration [kafka] - posted by "splett2 (via GitHub)" <gi...@apache.org> on 2024/01/12 17:15:11 UTC, 2 replies.

- [jira] [Commented] (KAFKA-16120) Partition reassignments in ZK migration dual write leaves stray partitions - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/12 17:19:00 UTC, 1 replies.

- [jira] [Comment Edited] (KAFKA-16120) Partition reassignments in ZK migration dual write leaves stray partitions - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/12 17:19:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16121) Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented - posted by "David Mao (Jira)" <ji...@apache.org> on 2024/01/12 17:32:00 UTC, 0 replies.

- Re: [PR] KAFKA-16120, KAFKA-16121: Handle removed replicas during KRaft migration [kafka] - posted by "splett2 (via GitHub)" <gi...@apache.org> on 2024/01/12 17:34:09 UTC, 1 replies.

- Re: [PR] KAFKA-15945 : Flaky test - testSyncTopicConfigs() – org.apache.kafka.connect.mirror.integration.MirrorConnectorsIntegrationBaseTest [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 17:53:06 UTC, 0 replies.

- Re: [PR] test [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/12 18:06:31 UTC, 0 replies.

- Re: [PR] KAFKA-14345: Fix flakiness with more accurate bound in (Dynamic)ConnectionQuotaTest [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 18:09:50 UTC, 0 replies.

- Re: [PR] MINOR: Stop leaking threads in BlockingConnectorTest [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 18:25:34 UTC, 1 replies.

- Re: [PR] KAFKA-5863: Avoid NPE when RestClient calls expecting no-content receive content. [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 18:30:26 UTC, 6 replies.

- [PR] KAFKA-15834: Remove NamedTopologyIntegrationTest which leaks clients [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 18:38:56 UTC, 4 replies.

- [jira] [Resolved] (KAFKA-16112) Review JMX metrics in Async Consumer and determine the missing ones - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/12 19:17:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16032) Review client error handling of OffsetFetch and OffsetCommit responses - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/12 20:23:00 UTC, 0 replies.

- Re: [PR] KAFKA-15816: Fix leaked sockets in core tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/12 21:15:53 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-15816) Typos in tests leak network sockets - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/12 21:20:00 UTC, 0 replies.

- Re: [PR] KAFKA-15047: Roll active segment when it breaches the retention policy [kafka] - posted by "junrao (via GitHub)" <gi...@apache.org> on 2024/01/12 22:46:28 UTC, 2 replies.

- [jira] [Resolved] (KAFKA-16051) Deadlock on connector initialization - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/12 23:47:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16122) TransactionsBounceTest -- server disconnected before response was received - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/12 23:50:00 UTC, 0 replies.

- [PR] KAFKA-16029: Fix "Unable to find FetchSessionHandler for node X" bug [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/01/13 00:01:06 UTC, 24 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 2024/01/13 00:40:00 UTC, 6 replies.

- [jira] [Commented] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/13 00:41:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16029) Investigate cause of "Unable to find FetchSessionHandler for node X" in logs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/13 00:42:00 UTC, 0 replies.

- Re: [PR] KAFKA-14957: Update-Description-String [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/13 01:00:09 UTC, 3 replies.

- Re: [PR] POC - DO NOT MERGE: Deprecation cleanup [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/13 03:33:18 UTC, 0 replies.

- Re: [PR] KAFKA-14648: Moving bootstrap to NetworkClient Poll. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/13 03:33:41 UTC, 0 replies.

- Re: [PR] KAFKA-15942: Implement ConsumerInterceptor [kafka] - posted by "Joker-5 (via GitHub)" <gi...@apache.org> on 2024/01/13 06:29:19 UTC, 5 replies.

- [PR] MINOR: add v3.5.2 in 3.6 branch [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/13 06:58:18 UTC, 1 replies.

- [PR] Kafka 15561: Client support for new SubscriptionPattern based subscription [kafka] - posted by "Phuc-Hong-Tran (via GitHub)" <gi...@apache.org> on 2024/01/13 11:40:36 UTC, 12 replies.

- [jira] [Created] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/01/13 12:06:00 UTC, 0 replies.

- [PR] KAFKA-16123: Fix KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. [kafka] - posted by "florin-akermann (via GitHub)" <gi...@apache.org> on 2024/01/13 12:21:30 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16123) KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window. - posted by "Florin Akermann (Jira)" <ji...@apache.org> on 2024/01/13 12:25:00 UTC, 1 replies.

- [PR] KAFKA-15811: Enhance request context with client socket port information (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/01/14 00:30:51 UTC, 12 replies.

- [jira] [Commented] (KAFKA-15958) Add tests to validate telemetry requests with different version - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/14 00:52:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15958) Add tests to validate telemetry requests with different version - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/14 00:52:00 UTC, 0 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 "Satish Duggana (Jira)" <ji...@apache.org> on 2024/01/14 00:53:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15952) Create public doc for telemetry state transition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/14 00:59:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15952) Create public doc for telemetry state transition - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/14 01:00:00 UTC, 0 replies.

- [PR] KAFKA-15743: KRaft support in ReplicationQuotasTest [kafka] - posted by "wernerdv (via GitHub)" <gi...@apache.org> on 2024/01/14 17:07:26 UTC, 2 replies.

- [jira] [Created] (KAFKA-16124) Create metrics.verbosity dynamic config for controlling metrics verbosity - posted by "Qichao Chu (Jira)" <ji...@apache.org> on 2024/01/14 20:35:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16125) Add parser for the metrics.verbosity config - posted by "Qichao Chu (Jira)" <ji...@apache.org> on 2024/01/14 21:28:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16126) Kcontroller dynamic configurations may fail to apply at startup - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/14 21:50:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16127) Reset corresponding verbosity configs when topic is deleted - posted by "Qichao Chu (Jira)" <ji...@apache.org> on 2024/01/14 21:51:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16127) Reset corresponding verbosity configs when topic is deleted - posted by "Qichao Chu (Jira)" <ji...@apache.org> on 2024/01/14 21:58:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16128) Use metrics.verbosity in throughput metrics - posted by "Qichao Chu (Jira)" <ji...@apache.org> on 2024/01/14 21:58:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16129) Add integration test for KIP-977 - posted by "Qichao Chu (Jira)" <ji...@apache.org> on 2024/01/14 22:01:00 UTC, 0 replies.

- [PR] KAFKA-16126: Kcontroller dynamic configurations may fail to apply at startup [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/01/14 22:07:57 UTC, 3 replies.

- [jira] [Resolved] (KAFKA-16120) Partition reassignments in ZK migration dual write leaves stray partitions - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/15 05:33:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16118) Coordinator unloading fails when replica is deleted - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/15 07:31:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16118) Coordinator unloading fails when replica is deleted - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/15 07:32:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16101) KRaft migration documentation is incorrect - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/15 08:07:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16101) KRaft migration documentation is incorrect - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/15 08:08:00 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-16101) KRaft migration documentation is incorrect - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/15 08:08:00 UTC, 0 replies.

- [PR] KAFKA-16101: KRaft migration documentation is incorrect [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/01/15 08:10:50 UTC, 27 replies.

- [jira] [Created] (KAFKA-16130) Test migration rollback - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/15 09:12:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16131) Repeated UnsupportedVersionException logged when running Kafka 3.7.0-RC2 KRaft cluster with metadata version 3.6 - posted by "Jakub Scholz (Jira)" <ji...@apache.org> on 2024/01/15 10:02:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16073) Kafka Tiered Storage: Consumer Fetch Error Due to Delayed localLogStartOffset Update During Segment Deletion - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/01/15 10:03:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15740) KRaft support in DeleteOffsetsConsumerGroupCommandIntegrationTest - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/15 10:56:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16132) Upgrading from 3.6 to 3.7 in KRaft will have seconds of partitions unavailable - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/15 12:56:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16132) Upgrading from 3.6 to 3.7 in KRaft will have seconds of partitions unavailable - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/15 12:57:00 UTC, 4 replies.

- [jira] [Commented] (KAFKA-16131) Repeated UnsupportedVersionException logged when running Kafka 3.7.0-RC2 KRaft cluster with metadata version 3.6 - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/15 12:58:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16133) Commits during reconciliation always time out - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/15 12:58:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16131) Repeated UnsupportedVersionException logged when running Kafka 3.7.0-RC2 KRaft cluster with metadata version 3.6 - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/15 13:19:00 UTC, 1 replies.

- [PR] KAFKA-16133 - Reconciliation auto-commit fix [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/01/15 14:36:41 UTC, 7 replies.

- [PR] KAFKA-16133: Reconciliation auto-commit fix [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/15 14:44:57 UTC, 1 replies.

- [jira] [Created] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 15:22:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 15:23:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 15:25:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16136) CoordinatorTest.testTaskRequestWithOldStartMsGetsUpdated() is very flaky - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 15:27:00 UTC, 0 replies.

- [PR] MINOR: Uniformize error handling/transformation in GroupCoordinatorService [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/15 16:48:51 UTC, 31 replies.

- [jira] [Assigned] (KAFKA-16137) ListClientMetricsResourcesResponse definition is missing field descriptions - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/15 17:28:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16137) ListClientMetricsResourcesResponse definition is missing field descriptions - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/15 17:28:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16138) QuotaTest system test fails consistently in 3.7 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 17:45:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16140) zookeeper_migration_test#TestMigration#test_recooncile_kraft_to_zk system test fails concistently on 3.7 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 17:48:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16139) StreamsUpgradeTest fails consistently in 3.7.0 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 17:48:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16141) StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{ “metadata_quorum”: “ISOLATED_KRAFT”, “use_new_coordinator”: false} fails consistently in 3.7 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 17:52:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16138) QuotaTest system test fails consistently in 3.7 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 17:55:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16141) StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{ “metadata_quorum”: “ISOLATED_KRAFT”, “use_new_coordinator”: false} fails consistently in 3.7 - posted by "Stanislav Kozlovski (Jira)" <ji...@apache.org> on 2024/01/15 17:55:00 UTC, 5 replies.

- [jira] [Updated] (KAFKA-15935) Flaky test: testRestartReplication() – org.apache.kafka.connect.mirror.integration.IdentityReplicationIntegrationTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/15 18:31:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16133) Commits during reconciliation always time out - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/15 18:40:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16032) Review client errors on OffsetFetch and OffsetCommit - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/15 18:55:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16032) Review client errors thrown on OffsetFetch and OffsetCommit failures - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/15 19:07:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/15 21:26:00 UTC, 3 replies.

- [jira] [Updated] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/15 21:27:00 UTC, 3 replies.

- [jira] [Created] (KAFKA-16142) Update metrics documentation for errors and new metrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/15 21:32:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16142) Update metrics documentation for errors and new metrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/15 21:32:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16143) New metrics for KIP-848 protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/15 21:33:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16131) Repeated UnsupportedVersionException logged when running Kafka 3.7.0-RC2 KRaft cluster with metadata version 3.6 - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2024/01/15 22:43:00 UTC, 0 replies.

- [PR] Kafka 16131: Only update directoryIds if the metadata version supports DirectoryAssignment [kafka] - posted by "pprovenzano (via GitHub)" <gi...@apache.org> on 2024/01/15 22:50:28 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-15341) Enabling TS for a topic during rolling restart causes problems - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/16 01:58:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15809) Update broker's metadata schema to include TS enable status - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/16 02:00:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-14507) Add ConsumerGroupPrepareAssignment API - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/16 02:00:00 UTC, 0 replies.

- Re: [PR] KAFKA-13988: Fix MM2 not consuming from latest when "auto.offset.reset=latest" is set [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/16 03:33:23 UTC, 2 replies.

- [jira] [Created] (KAFKA-16144) Controller leader checkQuorum timer should skip only 1 controller case - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/16 03:44:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16120) Fix partition reassignment during ZK migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/16 05:16:00 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-16121) Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/16 05:16:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16121) Partition reassignments in ZK migration dual write mode stalled until leader epoch incremented - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/16 05:27:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-14616) Topic recreation with offline broker causes permanent URPs - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/16 05:29:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16120) Fix partition reassignment during ZK migration - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/16 05:29:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16132) Upgrading from 3.6 to 3.7 in KRaft will have seconds of partitions unavailable - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/16 05:41:00 UTC, 0 replies.

- Re: [PR] KAFKA-14585: Move StorageTool to tools [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/16 09:00:43 UTC, 1 replies.

- [jira] [Commented] (KAFKA-16139) StreamsUpgradeTest fails consistently in 3.7.0 - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/01/16 10:31:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15734) KRaft support in BaseConsumerTest - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/01/16 10:34:00 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-15734) KRaft support in BaseConsumerTest - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/01/16 10:34:00 UTC, 0 replies.

- [PR] MINOR:The lock type of partitionMetadataLock can be downgraded from ReentrantReadWriteLock to ReentrantLock [kafka] - posted by "hudeqi (via GitHub)" <gi...@apache.org> on 2024/01/16 11:30:57 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16132) Upgrading from 3.6 to 3.7 in KRaft will have seconds of partitions unavailable - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/16 11:33:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16139) StreamsUpgradeTest fails consistently in 3.7.0 - posted by "Bruno Cadonna (Jira)" <ji...@apache.org> on 2024/01/16 12:08:00 UTC, 0 replies.

- [PR] KAFKA-16139: Fix StreamsUpgradeTest [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/01/16 12:27:34 UTC, 12 replies.

- [jira] [Created] (KAFKA-16145) Windows Kafka Shutdown - posted by "jeongbobae (Jira)" <ji...@apache.org> on 2024/01/16 12:30:00 UTC, 0 replies.

- Re: [PR] KAFKA-15875 Make Snapshot public [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2024/01/16 12:58:07 UTC, 0 replies.

- [jira] [Created] (KAFKA-16146) Checkpoint log-start-offset after remote log deletion - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/01/16 13:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16146) Checkpoint log-start-offset for remote log enabled topics - posted by "Kamal Chandraprakash (Jira)" <ji...@apache.org> on 2024/01/16 13:14:00 UTC, 1 replies.

- [PR] KAFKA-15992 Make MM2 heartbeats topic name configurable [kafka] - posted by "k0b3rIT (via GitHub)" <gi...@apache.org> on 2024/01/16 14:00:02 UTC, 0 replies.

- [PR] KAFKA-16146: Checkpoint log-start-offset for remote log enabled topics [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2024/01/16 14:07:49 UTC, 1 replies.

- [PR] KAFKA-16032: Fixes for commit/fetch error handling [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/01/16 15:36:02 UTC, 17 replies.

- [jira] [Commented] (KAFKA-15863) Handle push telemetry throttling with quota manager - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/16 16:03:00 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-15863) Handle push telemetry throttling with quota manager - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/16 16:03:00 UTC, 0 replies.

- [PR] [KAFKA-16124] Add metricss.verbosity config [kafka] - posted by "ex172000 (via GitHub)" <gi...@apache.org> on 2024/01/16 17:10:29 UTC, 0 replies.

- [PR] KAFKA-16097: Disable state updater in trunk (#15146) [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/16 17:36:28 UTC, 1 replies.

- [jira] [Created] (KAFKA-16147) Partition is assigned to two members at the same time - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/01/16 18:05:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16101) KRaft migration rollback documentation is incorrect - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/16 18:06:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16147) Partition is assigned to two members at the same time - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/01/16 18:11:00 UTC, 13 replies.

- [jira] [Resolved] (KAFKA-15834) Subscribing to non-existent topic blocks StreamThread from stopping - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/16 18:22:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15834) Subscribing to non-existent topic blocks StreamThread from stopping - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/16 18:22:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type - posted by "Ritika Reddy (Jira)" <ji...@apache.org> on 2024/01/16 18:30:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16147) Partition is assigned to two members at the same time - posted by "Emanuele Sabellico (Jira)" <ji...@apache.org> on 2024/01/16 18:40:00 UTC, 0 replies.

- Re: [PR] KAFKA-15878: KIP-768 - Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/01/16 18:59:14 UTC, 1 replies.

- [jira] [Updated] (KAFKA-15878) KIP-768: Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/16 19:01:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16141) StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{ “metadata_quorum”: “ISOLATED_KRAFT”, “use_new_coordinator”: false} fails consistently in 3.7 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/16 19:03:00 UTC, 3 replies.

- [jira] [Assigned] (KAFKA-16141) StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{ “metadata_quorum”: “ISOLATED_KRAFT”, “use_new_coordinator”: false} fails consistently in 3.7 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/16 19:03:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16148) Implement GroupMetadataManager#onUnloaded - posted by "Jeff Kim (Jira)" <ji...@apache.org> on 2024/01/16 20:45:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16083) Exclude throttle time when expiring inflight requests on a connection - posted by "Adithya Chandra (Jira)" <ji...@apache.org> on 2024/01/16 22:03:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16083) Exclude throttle time when expiring inflight requests on a connection - posted by "Adithya Chandra (Jira)" <ji...@apache.org> on 2024/01/16 22:04:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16149) Aggressively expire unused client connections - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/16 23:20:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16150) Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/16 23:27:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16151) Fix PlaintextConsumerTest.testPerPartitionLedMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/16 23:28:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16151) Fix PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/16 23:28:00 UTC, 3 replies.

- [jira] [Created] (KAFKA-16152) Fix PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionCreatedAfterRestart - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/16 23:28:00 UTC, 0 replies.

- [PR] MINOR: populate TopicName in ConsumerGroupDescribe [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/01/16 23:31:21 UTC, 4 replies.

- Re: [PR] KAFKA-16042: Add byte-rate metrics for topic and partition  [kafka] - posted by "ex172000 (via GitHub)" <gi...@apache.org> on 2024/01/17 00:20:30 UTC, 1 replies.

- Re: [PR] KAFKA-14505; [7/7] Always materialize the most recent committed offset [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/17 00:56:08 UTC, 4 replies.

- [jira] [Updated] (KAFKA-16009) Fix PlaintextConsumerTest.testMaxPollIntervalMsDelayInRevocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/17 01:04:00 UTC, 5 replies.

- [jira] [Updated] (KAFKA-16008) Fix PlaintextConsumerTest.testMaxPollIntervalMs - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/17 01:05:00 UTC, 4 replies.

- [PR] KAFKA-16104: Enable additional PlaintextConsumerTest tests for new consumer [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/01/17 01:29:48 UTC, 7 replies.

- [PR] MINOR: code cleanup [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/17 01:34:54 UTC, 2 replies.

- [PR] MINOR Removed unused CommittedOffsetsFile class. [kafka] - posted by "satishd (via GitHub)" <gi...@apache.org> on 2024/01/17 03:29:37 UTC, 7 replies.

- [PR] KAFKA-16113: Add committed and commit sensor to record metrics [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/01/17 03:49:57 UTC, 7 replies.

- [jira] [Commented] (KAFKA-15851) broker under replicated due to error java.nio.BufferOverflowException - posted by "Yu Wang (Jira)" <ji...@apache.org> on 2024/01/17 06:03:00 UTC, 0 replies.

- Re: [PR] KAFKA-16131: Only update directoryIds if the metadata version supports DirectoryAssignment [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/01/17 06:27:20 UTC, 7 replies.

- [jira] [Commented] (KAFKA-16022) AsyncKafkaConsumer sometimes complains “No current assignment for partition {}” - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/17 06:58:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16153) kraft_upgrade_test system test is broken - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/17 08:04:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-4759) Add support for subnet masks in SimpleACLAuthorizer - posted by "Szymon Scharmach (Jira)" <ji...@apache.org> on 2024/01/17 10:26:00 UTC, 3 replies.

- [PR] KAFKA-16095: Update list group state type filter to include the states for the new consumer group type [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2024/01/17 10:56:47 UTC, 24 replies.

- [jira] [Assigned] (KAFKA-16147) Partition is assigned to two members at the same time - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/17 11:07:00 UTC, 0 replies.

- [PR] KAFKA-16147; Partition is assigned to two members at the same time [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/17 11:24:24 UTC, 14 replies.

- [jira] [Created] (KAFKA-16154) Make broker changes to return an offset for LATEST_TIERED_TIMESTAMP - posted by "Christo Lolov (Jira)" <ji...@apache.org> on 2024/01/17 13:07:00 UTC, 0 replies.

- [PR] KAFKA-16154: Broker returns offset for LATEST_TIERED_TIMESTAMP [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/17 13:09:45 UTC, 5 replies.

- [jira] [Created] (KAFKA-16155) Investigate testAutoCommitIntercept - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/17 13:37:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16155) Investigate testAutoCommitIntercept - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/17 13:38:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16156) System test failing on endOffsets with negative timestamps - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/17 14:35:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16156) System test failing on endOffsets with negative timestamps - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/17 14:36:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/17 14:40:00 UTC, 5 replies.

- [jira] [Comment Edited] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/17 15:22:00 UTC, 1 replies.

- [jira] [Commented] (KAFKA-16150) Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/17 15:27:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16151) Fix PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/17 15:30:00 UTC, 0 replies.

- [PR] KAFKA-16137: Add missing RPC field descriptions [kafka] - posted by "AndrewJSchofield (via GitHub)" <gi...@apache.org> on 2024/01/17 15:38:28 UTC, 3 replies.

- [jira] [Created] (KAFKA-16157) Topic recreation with offline disk doesn't update leadership/shrink ISR correctly - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/17 16:36:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16157) Topic recreation with offline disk doesn't update leadership/shrink ISR correctly - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/17 16:41:00 UTC, 4 replies.

- [jira] [Commented] (KAFKA-16157) Topic recreation with offline disk doesn't update leadership/shrink ISR correctly - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/17 17:07:00 UTC, 5 replies.

- [PR] KAFKA-16107: Stop fetching while onPartitionsAssign completes [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/01/17 17:33:35 UTC, 15 replies.

- [PR] KAFKA-16115: Adding missing heartbeat metrics [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/01/17 18:47:17 UTC, 7 replies.

- Re: [PR] KAFKA-15804: Close SocketServer channels when calling shutdown before enableRequestProcessing [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/17 19:10:46 UTC, 0 replies.

- Re: [PR] KAFKA-15826: Close consumer when sink task is cancelled [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/17 19:15:47 UTC, 1 replies.

- [jira] [Commented] (KAFKA-16156) System test failing for new consumer on endOffsets with negative timestamps - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/17 19:20:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15878) KIP-768: Extend support for opaque (i.e. non-JWT) tokens in SASL/OAUTHBEARER - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/17 19:46:00 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-16150) Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/17 19:53:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16151) Fix PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/17 19:54:00 UTC, 0 replies.

- [PR] KAFKA-16141: Fix StreamsStandbyTask system test [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/17 21:04:48 UTC, 9 replies.

- [jira] [Created] (KAFKA-16158) Cleanup usage of `TimestampedBytesStore` interface - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/17 21:15:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16141) StreamsStandbyTask##test_standby_tasks_rebalanceArguments:{ “metadata_quorum”: “ISOLATED_KRAFT”, “use_new_coordinator”: false} fails consistently in 3.7 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/17 21:16:00 UTC, 0 replies.

- [PR] KAFKA-16107: Stop fetching while onPartitionsAssign completes  [kafka] - posted by "anurag-harness (via GitHub)" <gi...@apache.org> on 2024/01/17 21:22:24 UTC, 2 replies.

- [jira] [Resolved] (KAFKA-16139) StreamsUpgradeTest fails consistently in 3.7.0 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/17 21:31:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16159) Prune excessive logging from Telemetry Reporter - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/17 22:07:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16159) Prune excessive logging from Telemetry Reporter - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/17 22:09:00 UTC, 5 replies.

- [jira] [Resolved] (KAFKA-16131) Repeated UnsupportedVersionException logged when running Kafka 3.7.0-RC2 KRaft cluster with metadata version 3.6 - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/17 22:11:00 UTC, 0 replies.

- Re: [PR] KAFKA-15827: Prevent KafkaBasedLog subclasses from leaking passed-in clients [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/17 22:13:29 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected note in a tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/17 22:32:00 UTC, 2 replies.

- [jira] [Created] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected note in a tight loop - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/17 22:32:00 UTC, 0 replies.

- Re: [PR] KAFKA-15307: Update/errors for deprecated config [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/17 23:48:43 UTC, 0 replies.

- Re: [PR] KAFKA-15307: update/note deprecated configs [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/17 23:49:57 UTC, 10 replies.

- [jira] [Assigned] (KAFKA-16161) Avoid creating remote log metadata snapshot file in partition data directory. - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/01/18 00:16:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16161) Avoid creating remote log metadata snapshot file in partition data directory. - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/01/18 00:16:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16161) Avoid creating remote log metadata snapshot file in partition data directory. - posted by "Satish Duggana (Jira)" <ji...@apache.org> on 2024/01/18 00:16:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16078) InterBrokerProtocolVersion defaults to non-production MetadataVersion - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/18 00:38:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16078) Be more consistent about getting the latest MetadataVersion - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/18 00:39:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16078) Be more consistent about getting the latest MetadataVersion - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/18 00:39:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15770) org.apache.kafka.streams.integration.ConsistencyVectorIntegrationTest.shouldHaveSamePositionBoundActiveAndStandBy is flaky - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/18 01:25:00 UTC, 0 replies.

- [PR] KAFKA-15770: IQv2 must return immutable position [kafka] - posted by "mjsax (via GitHub)" <gi...@apache.org> on 2024/01/18 01:28:38 UTC, 4 replies.

- [jira] [Updated] (KAFKA-16139) StreamsUpgradeTest fails consistently in 3.7.0 - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/18 01:37:00 UTC, 0 replies.

- Re: [PR] MINOR: Don't log missing partitions at ERROR level [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/18 03:33:12 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16104) Enable additional PlaintextConsumerTest tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/18 04:15:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/18 04:17:00 UTC, 4 replies.

- [PR] MINOR Remove unreachable if-else block in ReplicaManager.scala [kafka] - posted by "drawxy (via GitHub)" <gi...@apache.org> on 2024/01/18 06:10:14 UTC, 6 replies.

- [jira] [Assigned] (KAFKA-15712) KRaft support in MultipleListenersWithSameSecurityProtocolBaseTest - posted by "Sushant Mahajan (Jira)" <ji...@apache.org> on 2024/01/18 07:57:00 UTC, 0 replies.

- Re: [PR] KAFKA-12359: Update Jetty to 11 [kafka] - posted by "tommyk-gears (via GitHub)" <gi...@apache.org> on 2024/01/18 08:10:04 UTC, 0 replies.

- [PR] KAFKA-14505; [8/8] Update offset delete paths [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/18 09:04:52 UTC, 16 replies.

- [PR] MINOR: Fix compilation issue in ReplicaManagerTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/18 09:49:54 UTC, 3 replies.

- [PR] KAFKA-15712: Added KRaft support to MultipleListenersWithSameSecurityProtocolBaseTest [kafka] - posted by "smjn (via GitHub)" <gi...@apache.org> on 2024/01/18 09:50:42 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/18 10:54:00 UTC, 0 replies.

- [PR] KAFKA-15727: Added KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest [kafka] - posted by "adixitconfluent (via GitHub)" <gi...@apache.org> on 2024/01/18 11:57:37 UTC, 1 replies.

- [PR] KAFKA-15717: KRaft support in LeaderEpochIntegrationTest [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/01/18 12:01:19 UTC, 5 replies.

- [jira] [Created] (KAFKA-16162) New created topics are unavailable after upgrading to 3.7 - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/18 12:15:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16162) New created topics are unavailable after upgrading to 3.7 - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/18 12:17:00 UTC, 5 replies.

- Re: [PR] KAFKA-15303: Avoid unnecessary re-serialization in FK-join [kafka] - posted by "alikelleci (via GitHub)" <gi...@apache.org> on 2024/01/18 12:28:17 UTC, 0 replies.

- Re: [PR] KAFKA-14505; [7/N] Always materialize the most recent committed offset [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/18 13:51:13 UTC, 20 replies.

- Re: [PR] KAFKA-13988:Fix mm2 auto.offset.reset=latest not working [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/18 14:55:43 UTC, 1 replies.

- [PR] DO NOT MERGE: Isolate Connect OffsetsApiIntegrationTest [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/18 15:24:02 UTC, 2 replies.

- [PR] DRAFT: State updater with synchronous remove [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/01/18 15:27:54 UTC, 0 replies.

- [PR] KAFKA-16159: MINOR - Removed debug log [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/01/18 15:29:08 UTC, 4 replies.

- [PR] DO NOT MERGE: Isolate Connect tests [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/18 16:04:30 UTC, 0 replies.

- [jira] [Created] (KAFKA-16163) Constant resignation/reelection of controller when starting a single node in combined mode - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/18 18:02:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16164) Pre-Vote - posted by "Alyssa Huang (Jira)" <ji...@apache.org> on 2024/01/18 18:05:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16163) Constant resignation/reelection of controller when starting a single node in combined mode - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/18 18:11:00 UTC, 0 replies.

- [PR] KAFKA-14616: Fix stray replica of recreated topics in KRaft mode [kafka] - posted by "cmccabe (via GitHub)" <gi...@apache.org> on 2024/01/18 18:56:42 UTC, 9 replies.

- [jira] [Created] (KAFKA-16165) Consumer invalid transition on expired poll interval - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/18 19:16:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-5863) Potential null dereference in DistributedHerder#reconfigureConnector() - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/18 19:42:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15807) Add support for compression/decompression of metrics - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/18 19:44:00 UTC, 0 replies.

- [PR] KAFKA-16164: Pre-Vote RPCs [part 1] [kafka] - posted by "ahuang98 (via GitHub)" <gi...@apache.org> on 2024/01/18 19:54:11 UTC, 0 replies.

- Re: [PR] KAFKA-16159: MINOR - Correcting logs to debug telemetry reporter [kafka] - posted by "philipnee (via GitHub)" <gi...@apache.org> on 2024/01/18 20:23:08 UTC, 7 replies.

- [jira] [Resolved] (KAFKA-16087) Tasks dropping incorrect records when errors.tolerance=all and errors reported asynchronously due to data race - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/18 21:28:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16166) Generify RetryWithToleranceOperator and ErrorReporter - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/18 21:34:00 UTC, 0 replies.

- [PR] KAFKA-16162: [WIP] [kafka] - posted by "pprovenzano (via GitHub)" <gi...@apache.org> on 2024/01/18 21:46:00 UTC, 4 replies.

- [PR] KAFKA-16166: Generify RetryWithToleranceOperator and ErrorReporter classes [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/18 21:46:48 UTC, 4 replies.

- [jira] [Commented] (KAFKA-16162) New created topics are unavailable after upgrading to 3.7 - posted by "Proven Provenzano (Jira)" <ji...@apache.org> on 2024/01/18 22:10:00 UTC, 7 replies.

- [PR] KAFKA-15813: Evict client instances from cache (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/01/18 22:45:31 UTC, 29 replies.

- [jira] [Created] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/19 00:09:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16037) Upgrade existing system tests to use new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/19 00:33:00 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-16111) Implement tests for tricky rebalance callback scenarios - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/19 00:50:00 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-16163) Constant resignation/reelection of controller when starting a single node in combined mode - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/19 03:11:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16144) Controller leader checkQuorum timer should skip only 1 controller case - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/19 03:12:00 UTC, 0 replies.

- Re: [PR] KAFKA-15610: Fix `CoreUtils.swallow()` test gaps [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/19 03:33:08 UTC, 1 replies.

- [PR] KAFKA-16144: skip checkQuorum for only 1 voter case [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/19 03:37:24 UTC, 9 replies.

- [jira] [Commented] (KAFKA-13607) Cannot use PEM certificate coding when parent defined file-based - posted by "Sergey Ivanov (Jira)" <ji...@apache.org> on 2024/01/19 07:57:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16144) Controller leader checkQuorum timer should skip only 1 controller case - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/19 08:45:00 UTC, 1 replies.

- Re: [PR] KAFKA-14277: Add event queue size method [kafka] - posted by "danielgospodinow (via GitHub)" <gi...@apache.org> on 2024/01/19 08:45:55 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16144) Controller leader checkQuorum timer should skip only 1 controller case - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/19 08:46:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16144) Controller leader checkQuorum timer should skip only 1 controller case - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/19 09:12:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16168) Implement GroupCoordinator.onPartitionsDeleted - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/19 09:49:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16148) Implement GroupMetadataManager#onUnloaded - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/19 10:50:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request - posted by "Francois Visconte (Jira)" <ji...@apache.org> on 2024/01/19 13:28:00 UTC, 9 replies.

- [jira] [Created] (KAFKA-16169) FencedException in commitAsync not propagated without callback - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/19 14:08:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16170) Infinite logs observed when running single node kafka in kraft mode with default KRaft properties in 3.7.0 RC2 - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2024/01/19 14:30:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16170) Continuous never ending logs observed when running single node kafka in kraft mode with default KRaft properties in 3.7.0 RC2 - posted by "Vedarth Sharma (Jira)" <ji...@apache.org> on 2024/01/19 14:38:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16170) Continuous never ending logs observed when running single node kafka in kraft mode with default KRaft properties in 3.7.0 RC2 - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/19 14:40:00 UTC, 0 replies.

- [PR] Note that Java 11 support for broker and tools is deprecated for removal in 4.0 [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/01/19 15:10:16 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16169) FencedException in commitAsync not propagated without callback - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/19 15:16:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16171) Controller failover during ZK migration can lead to controller unavailability for ZK brokers - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/19 15:55:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16171) Controller failover during ZK migration can lead to controller unavailability for ZK brokers - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/19 15:56:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16171) Controller failover during ZK migration can prevent metadata updates to ZK brokers - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/19 15:57:00 UTC, 3 replies.

- [jira] [Resolved] (KAFKA-16113) AsyncKafkaConsumer: Add missing offset commit metrics - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/19 16:22:00 UTC, 0 replies.

- [PR] KAFKA-16168; Implement GroupCoordinator.onPartitionsDeleted [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/19 16:23:59 UTC, 9 replies.

- [jira] [Created] (KAFKA-16172) Flaky test: testProducerConsumerOverrideLowerQuota – kafka.api.UserQuotaTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/19 16:44:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16173) Flaky test: testTimeoutMetrics – org.apache.kafka.controller.QuorumControllerMetricsIntegrationTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/19 16:46:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16174) Flaky test: testDescribeQuorumStatusSuccessful – org.apache.kafka.tools.MetadataQuorumCommandTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/19 16:48:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16175) Flaky test: testAsynchronousAuthorizerAclUpdatesDontBlockRequestThreads – kafka.api.SslAdminIntegrationTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/19 16:50:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-15776) Update delay timeout for DelayedRemoteFetch request - posted by "Francois Visconte (Jira)" <ji...@apache.org> on 2024/01/19 16:53:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/19 16:53:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16177) Flaky test: testBatchSizeZeroNoPartitionNoRecordKey – kafka.api.PlaintextProducerSendTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/19 16:54:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15811) implement capturing client port information from Socket Server - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2024/01/19 18:30:00 UTC, 0 replies.

- [PR] KAFKA-16171 Fix hybrid mode controller race [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/01/19 18:40:16 UTC, 6 replies.

- [jira] [Assigned] (KAFKA-16169) FencedException in commitAsync not propagated without callback - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/19 18:49:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/01/19 20:30:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator - posted by "Dongnuo Lyu (Jira)" <ji...@apache.org> on 2024/01/19 20:30:00 UTC, 6 replies.

- [jira] [Commented] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator - posted by "Philip Nee (Jira)" <ji...@apache.org> on 2024/01/19 20:37:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15826) WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/19 20:55:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15826) WorkerSinkTask leaks Consumer if plugin start or stop blocks indefinitely - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/19 20:55:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16179) NPE handle ApiVersions during controller failover - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2024/01/19 21:47:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16179) NPE handle ApiVersions during controller failover - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/19 22:02:00 UTC, 1 replies.

- Re: [PR] MINOR: Note that Java 11 support for broker and tools is deprecated for removal in 4.0 (KIP-1013) [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/01/19 22:08:10 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16180) Full metadata request sometimes fails during zk migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/20 00:38:00 UTC, 2 replies.

- [jira] [Created] (KAFKA-16180) Full metadata request sometimes fails during zk migration - posted by "Colin McCabe (Jira)" <ji...@apache.org> on 2024/01/20 00:38:00 UTC, 0 replies.

- [PR] streams-scala: remove collections-compat dependency when on Scala 2.13 [kafka] - posted by "mberndt123 (via GitHub)" <gi...@apache.org> on 2024/01/20 17:59:09 UTC, 2 replies.

- [PR] MINOR: Delete KafkaCSVMetricsReporter [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/01/21 03:08:38 UTC, 0 replies.

- Re: [PR] KAFKA-14484: [2/N] Move RequestLocal to storage module [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/21 03:33:08 UTC, 0 replies.

- Re: [PR] KAFKA-15094: RemoteIndexCache stats [kafka] - posted by "kamalcph (via GitHub)" <gi...@apache.org> on 2024/01/21 13:50:05 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15931) Cached transaction index gets closed if tiered storage read is interrupted - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/01/21 17:38:00 UTC, 0 replies.

- [PR] KAFKA-15931: Reopen TransactionIndex if channel is closed [kafka] - posted by "jeqo (via GitHub)" <gi...@apache.org> on 2024/01/21 17:42:52 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15931) Cached transaction index gets closed if tiered storage read is interrupted - posted by "Jorge Esteban Quilcate Otoya (Jira)" <ji...@apache.org> on 2024/01/21 17:53:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16181) Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh - posted by "Deng Ziming (Jira)" <ji...@apache.org> on 2024/01/22 02:39:00 UTC, 0 replies.

- Re: [PR] MINOR: KAFKA-15526 followup [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/22 03:33:13 UTC, 0 replies.

- Re: [PR] KIP-759: new DSL operation on KStreams interface [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/22 03:33:15 UTC, 1 replies.

- Re: [PR] KAFKA-12605 - make GZIP decompression use BufferSupplier [kafka] - posted by "funky-eyes (via GitHub)" <gi...@apache.org> on 2024/01/22 07:34:37 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16147) Partition is assigned to two members at the same time - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/22 09:17:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15752) KRaft support in SaslSslAdminIntegrationTest - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2024/01/22 09:50:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15191) Add support for Micrometer Observation - posted by "Marcin Grzejszczak (Jira)" <ji...@apache.org> on 2024/01/22 10:18:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16182) Flaky test - testClientInstanceId() - org.apache.kafka.clients.admin.KafkaAdminClientTest - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/22 11:33:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16183) Flaky test - testMetricsDuringTopicCreateDelete(String).quorum=zk – kafka.integration.MetricsDuringTopicCreationDeletionTest - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/22 11:38:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16184) Flaky test - testAlterReplicaLogDirs(String).quorum=kraft – kafka.api.PlaintextAdminIntegrationTest - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/22 11:53:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-10140) Incremental config api excludes plugin config changes - posted by "Ismael Juma (Jira)" <ji...@apache.org> on 2024/01/22 15:31:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16185) Fix client reconciliation of same assignment received in different epochs - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/22 16:19:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15832) Trigger client reconciliation based on manager poll - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/22 17:01:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16179) NPE handle ApiVersions during controller failover - posted by "Jason Gustafson (Jira)" <ji...@apache.org> on 2024/01/22 18:02:00 UTC, 0 replies.

- [PR] KAFKA-16179; Stop processing requests before stopping publishing [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/01/22 18:06:05 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16182) Flaky test - testClientInstanceId() - org.apache.kafka.clients.admin.KafkaAdminClientTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/22 18:20:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16177) Flaky test: testBatchSizeZeroNoPartitionNoRecordKey – kafka.api.PlaintextProducerSendTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/22 18:21:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-12605) kafka consumer churns through buffer memory iterating over records - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/22 18:21:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16176) Flaky test: testSendToPartitionWithFollowerShutdownShouldNotTimeout – kafka.api.PlaintextProducerSendTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/22 18:21:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16178) AsyncKafkaConsumer doesn't retry joining the group after rediscovering group coordinator - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/22 18:50:00 UTC, 0 replies.

- [PR] KAFKA-16087: Remove more leaky NamedTopologyIntegrationTest tests [kafka] - posted by "gharris1727 (via GitHub)" <gi...@apache.org> on 2024/01/22 19:11:13 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-16137) ListClientMetricsResourcesResponse definition is missing field descriptions - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2024/01/22 19:20:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15104) Flaky test MetadataQuorumCommandTest for method testDescribeQuorumReplicationSuccessful - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/22 21:27:00 UTC, 0 replies.

- [PR] MINOR: Update KIP-890 note [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/22 22:00:09 UTC, 4 replies.

- [jira] [Resolved] (KAFKA-16166) Generify RetryWithToleranceOperator and ErrorReporter - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/23 00:58:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16144) Controller leader checkQuorum timer should skip only 1 controller case - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/23 02:19:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27 - posted by "highluck (Jira)" <ji...@apache.org> on 2024/01/23 04:26:00 UTC, 2 replies.

- [jira] [Commented] (KAFKA-10659) Cogroup topology generation fails if input streams are repartitioned - posted by "Stanislav Spiridonov (Jira)" <ji...@apache.org> on 2024/01/23 10:03:00 UTC, 0 replies.

- Re: [PR] KAFKA-15018: Failing offset flush for EOS when secondary offset store writes fails for tombstone records [kafka] - posted by "vamossagar12 (via GitHub)" <gi...@apache.org> on 2024/01/23 11:38:57 UTC, 12 replies.

- [PR] MINOR: Remove controlPlaneRequestProcessor in BrokerServer [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/01/23 11:40:03 UTC, 1 replies.

- [jira] [Updated] (KAFKA-14920) Address timeouts and out of order sequences - posted by "Lan Ding (Jira)" <ji...@apache.org> on 2024/01/23 13:11:00 UTC, 0 replies.

- [PR] KAFKA-15853: Move PasswordEncoder to server-common [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/23 13:24:45 UTC, 7 replies.

- [PR] MINOR: Fix "No suitable checks publisher found" message during CI build [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/23 14:41:12 UTC, 1 replies.

- [PR] KAFKA-14589 [WIP] [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/01/23 14:58:39 UTC, 0 replies.

- [jira] [Created] (KAFKA-16186) Implement broker metrics for client telemetry usage - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/23 15:11:00 UTC, 0 replies.

- Re: [PR] KAFKA-14589 ConsumerGroupServiceTest rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/01/23 15:24:55 UTC, 19 replies.

- [jira] [Assigned] (KAFKA-15675) Fix flaky ConnectorRestartApiIntegrationTest.testMultiWorkerRestartOnlyConnector() test - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/23 17:06:00 UTC, 0 replies.

- Re: [PR] KAFKA-16164: Pre-Vote, modifying vote RPCs [part 1] [kafka] - posted by "hachikuji (via GitHub)" <gi...@apache.org> on 2024/01/23 17:29:17 UTC, 5 replies.

- [jira] [Assigned] (KAFKA-14576) Move ConsoleConsumer to tools - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/23 17:32:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-14576) Move ConsoleConsumer to tools - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/23 17:34:00 UTC, 1 replies.

- [jira] [Commented] (KAFKA-15675) Fix flaky ConnectorRestartApiIntegrationTest.testMultiWorkerRestartOnlyConnector() test - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/23 17:37:00 UTC, 0 replies.

- [PR] KAFKA-15675: Improve worker liveness check during Connect integration tests [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/23 17:53:23 UTC, 7 replies.

- [jira] [Created] (KAFKA-16187) Flaky test: testTopicPatternArg - org.apache.kafka.tools.GetOffsetShellTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/23 20:29:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15683) Delete subscription from metadata when all configs are deleted - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/23 20:36:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15343) Fix MirrorConnectIntegrationTests causing ci build failures. - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/23 22:40:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15343) Fix MirrorConnectIntegrationTests causing ci build failures. - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/23 22:54:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15813) Improve implementation of client instance cache - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2024/01/23 23:07:00 UTC, 0 replies.

- [PR] [WIP - DON'T MERGE] KAFKA-15974 Enforce that CompletableApplicationEvent has a timeout that is respected [kafka] - posted by "kirktrue (via GitHub)" <gi...@apache.org> on 2024/01/23 23:42:20 UTC, 0 replies.

- Re: [PR] MINOR: Delete unused classes [kafka] - posted by "ijuma (via GitHub)" <gi...@apache.org> on 2024/01/24 06:04:46 UTC, 0 replies.

- [jira] [Created] (KAFKA-16188) Delete deprecated kafka.common.MessageReader - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/24 09:36:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-14577) Move ConsoleProducer to tools - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/24 09:38:00 UTC, 0 replies.

- [PR] KAFKA-16186: Broker metrics for client telemetry (KIP-714) [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/01/24 10:32:54 UTC, 28 replies.

- [jira] [Created] (KAFKA-16189) Extend admin to support ConsumerGroupDescribe API - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/24 10:35:00 UTC, 0 replies.

- [PR] MINOR: cleanup core modules part 1 [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2024/01/24 11:30:54 UTC, 6 replies.

- [PR] KAFKA-16189; Extend admin to support ConsumerGroupDescribe API [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/24 12:25:57 UTC, 11 replies.

- [jira] [Resolved] (KAFKA-16107) Ensure consumer does not start fetching from added partitions until onPartitionsAssigned completes - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/24 12:35:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16185) Fix client reconciliation of same assignment received in different epochs - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/24 14:46:00 UTC, 3 replies.

- [PR] KAFKA-14133: Move stateDirectory mock in TaskManagerTest to Mockito [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/24 15:02:16 UTC, 1 replies.

- [PR] MINOR: Mark ConsumerGroupDescribe API as stable [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/24 16:05:00 UTC, 3 replies.

- [jira] [Created] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/24 16:16:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/24 16:41:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16134) kafka.api.PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/24 16:44:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16135) kafka.api.PlaintextConsumerTest.testPerPartitionLeadMetricsCleanUpWithSubscribe(String, String).quorum=kraft+kip848.groupProtocol=consumer is flaky - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/24 16:54:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/24 16:56:00 UTC, 3 replies.

- [PR] KAFKA-14589 [1/3][WIP] Tests of ConsoleGroupCommand rewritten in java [kafka] - posted by "nizhikov (via GitHub)" <gi...@apache.org> on 2024/01/24 17:19:53 UTC, 0 replies.

- [jira] [Created] (KAFKA-16191) Clean up of consumer client internal events - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/24 18:15:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16191) Clean up of consumer client internal events - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/24 18:16:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16192) Introduce usage of flexible records to coordinators - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/24 18:34:00 UTC, 0 replies.

- [PR] Minor update to KafkaApisTest [kafka] - posted by "chb2ab (via GitHub)" <gi...@apache.org> on 2024/01/24 18:56:32 UTC, 4 replies.

- [PR] MINOR: Store separate output per test case instead of suite [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/24 19:56:30 UTC, 1 replies.

- Re: [PR] KAFKA-14404: fix overlap of streams-config sections & describe additional parameters [kafka] - posted by "ableegoldman (via GitHub)" <gi...@apache.org> on 2024/01/24 22:04:45 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16192) Introduce usage of flexible records to coordinators - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/24 22:47:00 UTC, 1 replies.

- Re: [PR] KAFKA-15608: Assign lastet leader eopch and offset checkpoint to future log when replacing current log [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/25 03:33:11 UTC, 0 replies.

- [jira] [Created] (KAFKA-16193) Storing mm2 topics on source side - posted by "Mikhail Filatov (Jira)" <ji...@apache.org> on 2024/01/25 06:46:00 UTC, 0 replies.

- [PR] Add groupType enum class [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/01/25 06:51:27 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/25 09:13:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-7957) Flaky Test DynamicBrokerReconfigurationTest#testMetricsReporterUpdate - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/25 09:14:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-10413) rebalancing leads to unevenly balanced connectors - posted by "yazgoo (Jira)" <ji...@apache.org> on 2024/01/25 10:17:00 UTC, 0 replies.

- [PR] KAFKA-15853: Refactor org.apache.kafka.server.config.Defaults to follow Java config pattern [kafka] - posted by "OmniaGM (via GitHub)" <gi...@apache.org> on 2024/01/25 12:28:36 UTC, 4 replies.

- [jira] [Created] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/25 13:14:00 UTC, 0 replies.

- Re: [PR] KAFKA-15462: Add groupType enum for KIP-848 [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/25 13:18:49 UTC, 2 replies.

- [PR] KAFKA-14133: Move consumer mock in TaskManagerTest to Mockito - part 2 [kafka] - posted by "clolov (via GitHub)" <gi...@apache.org> on 2024/01/25 13:47:41 UTC, 5 replies.

- [jira] [Created] (KAFKA-16195) metadata.log.dir failure shouldn't shutdown broker in ZK mode - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/25 13:49:00 UTC, 0 replies.

- [PR] KAFKA-16195: ignore metadata.log.dir failure in ZK mode [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/01/25 13:56:32 UTC, 7 replies.

- [jira] [Updated] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/25 14:08:00 UTC, 5 replies.

- [jira] [Resolved] (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 2024/01/25 14:47:00 UTC, 0 replies.

- [PR] KAFKA-16157: fix topic recreation handling with offline disks [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/01/25 14:55:13 UTC, 18 replies.

- [PR] KAFKA-14412: Add statestore.uncommitted.max.bytes [kafka] - posted by "nicktelford (via GitHub)" <gi...@apache.org> on 2024/01/25 15:09:05 UTC, 15 replies.

- [jira] [Commented] (KAFKA-16193) Storing mm2 topics on source side - posted by "Greg Harris (Jira)" <ji...@apache.org> on 2024/01/25 18:32:00 UTC, 0 replies.

- Re: [PR] KAFKA-14589 ConsumerGroupCommand rewritten in java [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/25 19:29:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16162) New created topics are unavailable after upgrading to 3.7 - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/25 19:32:00 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-10816) Connect REST API should have a resource that can be used as a readiness probe - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/25 19:34:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-10816) Connect REST API should have a resource that can be used as a readiness probe - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/25 19:35:00 UTC, 0 replies.

- [PR] MINOR: Handle retriable errors in TxnOffsetCommits [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/26 00:27:19 UTC, 0 replies.

- [jira] [Created] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully - posted by "Yash Mayya (Jira)" <ji...@apache.org> on 2024/01/26 00:52:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16196) Cast transform doesn't handle invalid whole value casts gracefully - posted by "Yash Mayya (Jira)" <ji...@apache.org> on 2024/01/26 00:53:00 UTC, 3 replies.

- [PR] KAFKA-16196: Handle invalid whole value casts in the Cast transform gracefully [kafka] - posted by "yashmayya (via GitHub)" <gi...@apache.org> on 2024/01/26 00:58:26 UTC, 3 replies.

- [PR] [Draft] Join, Sync, Heartbeat during Migration [kafka] - posted by "dongnuo123 (via GitHub)" <gi...@apache.org> on 2024/01/26 02:44:33 UTC, 6 replies.

- Re: [PR] MINOR: Fix NPE during fetchSnapshot [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/26 03:33:15 UTC, 3 replies.

- Re: [PR] MINOR: Remove unreachable if-else block in ReplicaManager.scala [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/26 06:46:41 UTC, 1 replies.

- Re: [PR] MINOR: Remove controlPlaneRequestProcessor in BrokerServer. [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/01/26 07:49:41 UTC, 0 replies.

- Re: [PR] KAFKA-15717: Added KRaft support in LeaderEpochIntegrationTest [kafka] - posted by "appchemist (via GitHub)" <gi...@apache.org> on 2024/01/26 07:59:45 UTC, 0 replies.

- [jira] [Created] (KAFKA-16197) Connect Worker poll timeout prints Consumer poll timeout specific warnings. - posted by "Sagar Rao (Jira)" <ji...@apache.org> on 2024/01/26 08:02:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16197) Connect Worker poll timeout prints Consumer poll timeout specific warnings. - posted by "Sagar Rao (Jira)" <ji...@apache.org> on 2024/01/26 08:16:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16198) Reconciliation may lose partitions when topic metadata is delayed - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/26 09:49:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16198) Reconciliation may lose partitions when topic metadata is delayed - posted by "Lucas Brutschy (Jira)" <ji...@apache.org> on 2024/01/26 09:50:00 UTC, 2 replies.

- Re: [PR] KAFKA-14589 [1/3] Tests of ConsoleGroupCommand rewritten in java [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/26 12:13:45 UTC, 15 replies.

- [PR] MINOR: Re-add Uniform assignor to the default ones [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/26 13:10:03 UTC, 3 replies.

- [jira] [Resolved] (KAFKA-14505) Implement TnxOffsetCommit API - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/26 13:18:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15929) Flaky test - testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress - TopicCommandIntegrationTest - posted by "Josep Prat (Jira)" <ji...@apache.org> on 2024/01/26 13:45:00 UTC, 0 replies.

- [PR] KAFKA-16162: resend broker registration on metadata update to IBP 3.7-IV2 [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/01/26 14:56:23 UTC, 14 replies.

- [PR] KAFKA-16198: Reconciliation may lose partitions when topic metadata is delayed [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/26 14:57:31 UTC, 20 replies.

- [PR] MINOR: Clean up core server classes [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2024/01/26 16:24:00 UTC, 8 replies.

- [jira] [Assigned] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Quoc Phong Dang (Jira)" <ji...@apache.org> on 2024/01/26 16:29:00 UTC, 2 replies.

- [PR] KAFKA-14585: Refactoring for moving the storage tool [kafka] - posted by "fvaleri (via GitHub)" <gi...@apache.org> on 2024/01/26 16:47:46 UTC, 8 replies.

- [PR] KAFKA-14576: Move ConsoleConsumer to tools [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/26 16:51:46 UTC, 4 replies.

- [PR] KAFKA-15832: Trigger client reconciliation based on manager poll [kafka] - posted by "lucasbru (via GitHub)" <gi...@apache.org> on 2024/01/26 18:12:49 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15987) Refactor ReplicaManager code for transaction verification - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/26 18:34:00 UTC, 0 replies.

- Re: [PR] KAFKA-16122: Handle retriable errors in TxnOffsetCommits [kafka] - posted by "jolshan (via GitHub)" <gi...@apache.org> on 2024/01/26 18:59:24 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16122) TransactionsBounceTest -- server disconnected before response was received - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/26 19:07:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15974) Enforce that CompletableApplicationEvent has a timeout that is respected - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/26 20:41:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-15974) Enforce that events and requests respect user-provided timeouts - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/26 20:44:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16100) Add timeout to all the CompletableApplicationEvents - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/26 20:44:00 UTC, 6 replies.

- [jira] [Created] (KAFKA-16199) Prune the event queue if events have expired before starting - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/26 20:45:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16200) Ensure RequestManager handling of expired timeouts are consistent - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/26 20:46:00 UTC, 0 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 2024/01/26 20:48:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-15848) Consumer API timeout inconsistent between ConsumerDelegate implementations - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/26 20:48:00 UTC, 7 replies.

- [jira] [Commented] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/27 00:33:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16169) FencedException in commitAsync not propagated without callback - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/27 00:34:00 UTC, 0 replies.

- [jira] (KAFKA-16190) Member should send full heartbeat when rejoining - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/27 00:35:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16199) Prune the event queue if events have expired before starting - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/27 00:35:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16200) Ensure RequestManager handling of expired timeouts are consistent - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/27 00:35:00 UTC, 3 replies.

- Re: [PR] Change `CreateTopicPolicy.RequestMetadata` to always provide partitions, replication factor and replica assignments. [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/27 03:33:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16066) Upgrade apacheds to 2.0.0.AM27 - posted by "highluck (Jira)" <ji...@apache.org> on 2024/01/27 04:01:00 UTC, 0 replies.

- [PR] Deprecate long based range queries in SessionStore [kafka] - posted by "armdave (via GitHub)" <gi...@apache.org> on 2024/01/27 06:24:50 UTC, 0 replies.

- [PR] KAFKA-16066: Upgrade apacheds to 2.0.0.AM27(change apache kerby) [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/01/27 07:06:51 UTC, 1 replies.

- [jira] [Commented] (KAFKA-13840) KafkaConsumer is unable to recover connection to group coordinator after commitOffsetsAsync exception - posted by "kaiyangzhang (Jira)" <ji...@apache.org> on 2024/01/27 09:09:00 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-16085) remote copy lag bytes/segments metrics don't update all topic value - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/27 11:15:00 UTC, 0 replies.

- [PR] MINOR: Move SplitSegmentResult to storage module [kafka] - posted by "DL1231 (via GitHub)" <gi...@apache.org> on 2024/01/27 13:11:54 UTC, 0 replies.

- Re: [PR] KAFKA-10338; Support PEM format for SSL key and trust stores (KIP-651) [kafka] - posted by "bachmanity1 (via GitHub)" <gi...@apache.org> on 2024/01/27 13:33:05 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-15715) KRaft support in UpdateFeaturesTest - posted by "highluck (Jira)" <ji...@apache.org> on 2024/01/27 13:41:00 UTC, 1 replies.

- Re: [PR] KAFKA-13130: Deprecate long based range queries in SessionStore [kafka] - posted by "armdave (via GitHub)" <gi...@apache.org> on 2024/01/27 16:42:38 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15716) KRaft support in EpochDrivenReplicationProtocolAcceptanceTest - posted by "highluck (Jira)" <ji...@apache.org> on 2024/01/27 17:24:00 UTC, 0 replies.

- Re: [PR] KAFKA-16066: remove apacheds to 2.0.0.AM27(change apache kerby) [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/27 20:50:01 UTC, 4 replies.

- [jira] [Assigned] (KAFKA-16088)  Not reading active segments  when RemoteFetch return Empty Records. - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/28 04:42:00 UTC, 0 replies.

- [jira] [Comment Edited] (KAFKA-16088)  Not reading active segments  when RemoteFetch return Empty Records. - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/28 09:52:00 UTC, 1 replies.

- Re: [PR] Initial support for OpenJDK CRaC snapshotting [kafka] - posted by "tzvetkovg (via GitHub)" <gi...@apache.org> on 2024/01/28 12:09:34 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-16195) metadata.log.dir failure shouldn't shutdown broker in ZK mode - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/28 12:39:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16162) New created topics are unavailable after upgrading to 3.7 - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/28 12:40:00 UTC, 0 replies.

- Re: [PR] KAFKA-15396:Add a metric indicating the version of the current running kafka server [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/29 03:33:46 UTC, 0 replies.

- Re: [PR] KAFKA-14517: Implement regex subscriptions [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/29 08:33:56 UTC, 12 replies.

- [jira] [Updated] (KAFKA-16017) Checkpointed offset is incorrect when task is revived and restoring - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/29 08:35:00 UTC, 0 replies.

- [PR] MINOR: Clean up core metrics, migration, network, raft, security, serializer, tools, utils, and zookeeper modules [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2024/01/29 10:00:59 UTC, 6 replies.

- [jira] [Created] (KAFKA-16201) Kafka exception - org.apache.kafka.common.errors.NotLeaderOrFollowerException - posted by "Yogesh (Jira)" <ji...@apache.org> on 2024/01/29 10:09:00 UTC, 0 replies.

- [PR] MINOR: add client info in authentication error log [kafka] - posted by "showuon (via GitHub)" <gi...@apache.org> on 2024/01/29 12:34:19 UTC, 5 replies.

- Re: [PR] KAFKA-10816: Initialize REST endpoints only after the herder has started [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/29 14:08:16 UTC, 0 replies.

- Re: [PR] KAFKA-10816: Use root resource as readiness and health probe for Connect distributed mode [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/29 14:08:27 UTC, 0 replies.

- [jira] [Created] (KAFKA-16202) Extra dot in error message in producer - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/29 14:39:00 UTC, 0 replies.

- [PR] Fix to include runtime dependencies in clients [kafka] - posted by "apoorvmittal10 (via GitHub)" <gi...@apache.org> on 2024/01/29 14:47:08 UTC, 6 replies.

- [jira] [Created] (KAFKA-16203) AutoCommit of empty offsets blocks following requests due to inflight flag - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/29 14:53:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16203) AutoCommit of empty offsets blocks following requests due to inflight flag - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/29 15:00:00 UTC, 1 replies.

- [PR] KAFKA-16203: Fix bug on auto-commit empty offsets blocking inflight [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/01/29 15:02:39 UTC, 1 replies.

- [jira] [Resolved] (KAFKA-16095) Update list group state type filter to include the states for the new consumer group type - posted by "David Jacot (Jira)" <ji...@apache.org> on 2024/01/29 15:20:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16204) Stray file core/00000000000000000001.snapshot created when running core tests - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/29 15:41:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16194) KafkaConsumer.groupMetadata() should be correct when first records are returned - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/29 16:22:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16204) Stray file core/00000000000000000001.snapshot created when running core tests - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/29 16:55:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16205) Reduce number of metadata requests during hybrid mode - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/29 17:14:00 UTC, 0 replies.

- [PR] KAFKA-16205 Allow MetadataLoader to coalesce small batches [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/01/29 17:23:23 UTC, 0 replies.

- [jira] [Created] (KAFKA-16206) ZkConfigMigrationClient tries to delete topic configs twice - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/29 17:54:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16205) Reduce number of metadata requests during hybrid mode - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/29 17:55:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16206) KRaftMigrationZkWriter tries to delete deleted topic configs twice - posted by "David Arthur (Jira)" <ji...@apache.org> on 2024/01/29 17:57:00 UTC, 0 replies.

- [PR] Update jose4j to 0.9.4 to address CVE-2023-51775 [kafka] - posted by "mike-lloyd03 (via GitHub)" <gi...@apache.org> on 2024/01/29 19:40:58 UTC, 0 replies.

- Re: [PR] KAFKA-14725: Interrupt source task poll thread when cancelled [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/29 20:12:45 UTC, 0 replies.

- [PR] KAFKA-16107 [2/N]: Fix inverted args & more tests [kafka] - posted by "lianetm (via GitHub)" <gi...@apache.org> on 2024/01/29 21:11:39 UTC, 3 replies.

- [jira] [Created] (KAFKA-16207) Implement KRaft internal listener for KRaftVersionRecord and VotersRecord - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/01/29 23:06:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-14094) KIP-853: KRaft controller membership changes - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/01/29 23:13:00 UTC, 1 replies.

- [jira] [Created] (KAFKA-16208) Design new Consumer timeout policy - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 00:25:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16199) Prune the event queue if event timeout expired before starting - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 00:26:00 UTC, 3 replies.

- [jira] [Updated] (KAFKA-15974) Enforce that events and requests respect user-provided timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 00:27:00 UTC, 4 replies.

- [jira] [Updated] (KAFKA-15475) Request might retry forever even if the user API timeout expires - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 00:28:00 UTC, 3 replies.

- [jira] [Updated] (KAFKA-16010) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnStopPolling - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 00:30:00 UTC, 4 replies.

- [jira] [Updated] (KAFKA-16204) Stray file core/00000000000000000001.snapshot created when running core tests - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/30 00:30:00 UTC, 0 replies.

- [PR] MINOR kip 848 uniform assignor bugs [kafka] - posted by "rreddy-22 (via GitHub)" <gi...@apache.org> on 2024/01/30 02:26:41 UTC, 0 replies.

- [jira] [Created] (KAFKA-16209) fetchSnapshot might return null if topic is created before v2.8 - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/30 03:22:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16209) fetchSnapshot might return null if topic is created before v2.8 - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/30 03:22:00 UTC, 0 replies.

- Re: [PR] KAFKA-13328, KAFKA-13329 (2): Add custom preflight validation support for connector header, key, and value converters [kafka] - posted by "github-actions[bot] (via GitHub)" <gi...@apache.org> on 2024/01/30 03:33:31 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16209) fetchSnapshot might return null if topic is created before v2.8 - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/30 03:56:00 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-16209) fetchSnapshot might return null if topic is created before v2.8 - posted by "Arpit Goyal (Jira)" <ji...@apache.org> on 2024/01/30 03:56:00 UTC, 0 replies.

- Re: [PR] MINOR: KIP-848 Uniform Assignor Bugs [kafka] - posted by "dajac (via GitHub)" <gi...@apache.org> on 2024/01/30 07:49:33 UTC, 0 replies.

- [PR] KAFKA-16101: Additional fixes on KRaft migration documentation [kafka] - posted by "ppatierno (via GitHub)" <gi...@apache.org> on 2024/01/30 08:41:38 UTC, 3 replies.

- [jira] [Created] (KAFKA-16210) Upgrade jose4j to 0.9.4 - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/30 10:09:00 UTC, 0 replies.

- Re: [PR] KAFKA-16210: Update jose4j to 0.9.4 [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/01/30 10:16:05 UTC, 2 replies.

- [jira] [Resolved] (KAFKA-16210) Upgrade jose4j to 0.9.4 - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/30 10:22:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16210) Upgrade jose4j to 0.9.4 - posted by "Divij Vaidya (Jira)" <ji...@apache.org> on 2024/01/30 10:22:00 UTC, 0 replies.

- [PR] KAFKA-16204: Create partition dir for mockLog [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/01/30 10:59:10 UTC, 7 replies.

- [jira] [Assigned] (KAFKA-16204) Stray file core/00000000000000000001.snapshot created when running core tests - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/30 11:00:00 UTC, 0 replies.

- [PR] MINOR: update gitignore to add core/data2 [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/01/30 11:01:35 UTC, 4 replies.

- [jira] [Assigned] (KAFKA-16157) Topic recreation with offline disk doesn't update leadership/shrink ISR correctly - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/30 11:04:00 UTC, 0 replies.

- [PR] MINOR: Fixes broken build [kafka] - posted by "jlprat (via GitHub)" <gi...@apache.org> on 2024/01/30 11:16:34 UTC, 4 replies.

- [PR] Update jetty to 9.4.53.v20231009 for CVE-2023-36478 [kafka] - posted by "ehumber (via GitHub)" <gi...@apache.org> on 2024/01/30 14:27:32 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16204) Stray file core/00000000000000000001.snapshot created when running core tests - posted by "Mickael Maison (Jira)" <ji...@apache.org> on 2024/01/30 15:05: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 2024/01/30 16:36:00 UTC, 3 replies.

- [jira] [Updated] (KAFKA-16208) Design new Consumer timeout policy - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 17:00:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16165) Consumer invalid transition on expired poll interval - posted by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/01/30 17:44:00 UTC, 4 replies.

- [jira] [Resolved] (KAFKA-10184) Flaky HighAvailabilityTaskAssignorIntegrationTest.shouldScaleOutWithWarmupTasksAndPersistentStores - posted by "Matthias J. Sax (Jira)" <ji...@apache.org> on 2024/01/30 17:44:00 UTC, 0 replies.

- Re: [PR] MINOR: Cleanup log.dirs in ReplicaManagerTest on JVM exit [kafka] - posted by "gaurav-narula (via GitHub)" <gi...@apache.org> on 2024/01/30 17:49:54 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-8606) Provide a method to fetch committed offsets for a collection of TopicPartition - posted by "Andrew Schofield (Jira)" <ji...@apache.org> on 2024/01/30 18:19:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16211) Inconsistent static config values in CreateTopicsResult and DescribeConfigsResult - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2024/01/30 18:32:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16211) Inconsistent config values in CreateTopicsResult and DescribeConfigsResult - posted by "Gantigmaa Selenge (Jira)" <ji...@apache.org> on 2024/01/30 18:32:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15773) Group protocol configuration should be validated - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:49: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 2024/01/30 18:49:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15872) Investigate autocommit retry logic - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:52:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15270) Integration tests for AsyncConsumer simple consume case - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:52:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15515) Remove duplicated integration tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:52:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-15539) Client should stop fetching while partitions being revoked - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:53:00 UTC, 0 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 2024/01/30 18:53: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 2024/01/30 18:53:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15573) Implement auto-commit on partition assignment revocation - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:53: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 2024/01/30 18:53:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15840) Correct initialization of ConsumerGroupHeartbeat by client - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:53:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15694) New integration tests to have full coverage for preview - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:53:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15543) Send HB request right after reconciliation completes - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:53:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15651) Investigate auto commit guarantees during Consumer.assign() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:53:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16011) Fix PlaintextConsumerTest.testMultiConsumerSessionTimeoutOnClose - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:58:00 UTC, 4 replies.

- [jira] [Updated] (KAFKA-15325) Integrate topicId in OffsetFetch and OffsetCommit async consumer calls - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:59:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15692) New integration tests to ensure full coverage - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 18:59:00 UTC, 1 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 2024/01/30 18:59:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16143) New metrics for KIP-848 protocol - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:01:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16112) Review JMX metrics in Async Consumer and determine the missing ones - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:02:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16142) Update metrics documentation for errors and new metrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:02:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-15908) Remove deprecated Consumer API poll(long timeout) - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:04:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-10228) producer: NETWORK_EXCEPTION is thrown instead of a request timeout - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:07:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-13703) OAUTHBEARER client will not use defined truststore - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:07:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-14830) Illegal state error in transactional producer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:07:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15932) Flaky test - PlaintextConsumerTest.testSeek("kraft+kip-848","consumer") - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:11:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15991) Flaky new consumer test testGroupIdNotNullAndValid - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:11:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16150) Fix PlaintextConsumerTest.testPerPartitionLagMetricsCleanUpWithSubscribe - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:11:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-16152) Fix PlaintextConsumerTest.testStaticConsumerDetectsNewPartitionCreatedAfterRestart - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:11:00 UTC, 2 replies.

- [jira] [Updated] (KAFKA-16167) Fix PlaintextConsumerTest.testAutoCommitOnCloseAfterWakeup - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:11:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15971) Re-enable consumer integration tests for new consumer - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:11:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15986) New consumer group protocol integration test failures - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:11:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15641) Investigate CompletedFetch handleInitializeErrors for accuracy - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15636) Investigate FetcherTest's/FetchRequestManager's testFetchResponseMetrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15606) Investigate FetcherTest's/FetchRequestManager's testCompletedFetchRemoval - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15635) Investigate FetcherTest's/FetchRequestManager's testFetcherLeadMetric - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15637) Investigate FetcherTest's/FetchRequestManager's testFetchCompletedBeforeHandlerAdded - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15634) Investigate FetcherTest's/FetchRequestManager's testQuotaMetrics - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-14724) Port tests in FetcherTest to FetchRequestManagerTest - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15617) Investigate FetcherTest's/FetchRequestManager's testFetchingPendingPartitions and testInflightFetchOnPendingPartitions overlap - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:13:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15867) Should ConsumerNetworkThread wrap the exception and notify the polling thread? - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:34:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-15942) Implement ConsumerInterceptor - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:35:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16133) Commits during reconciliation always time out - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:42:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16110) Implement consumer performance tests - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:46:00 UTC, 0 replies.

- [jira] [Updated] (KAFKA-16023) PlaintextConsumerTest needs to wait for reconciliation to complete before proceeding - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:49:00 UTC, 1 replies.

- [jira] [Updated] (KAFKA-15652) Add tests to verify OffsetFetcherUtils.getOffsetResetTimestamp() - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/30 19:50:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-15772) Flaky test TransactionsWithTieredStoreTest - posted by "Apoorv Mittal (Jira)" <ji...@apache.org> on 2024/01/30 21:26:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16186) Implement broker metrics for client telemetry usage - posted by "Jun Rao (Jira)" <ji...@apache.org> on 2024/01/30 23:07:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-15692) New integration tests to ensure full coverage - posted by "Kirk True (Jira)" <ji...@apache.org> on 2024/01/31 01:37:00 UTC, 0 replies.

- [jira] [Resolved] (KAFKA-16101) KRaft migration rollback documentation is incorrect - posted by "Luke Chen (Jira)" <ji...@apache.org> on 2024/01/31 07:26:00 UTC, 0 replies.

- [PR] feat: Create topic by specifying topic id [kafka] - posted by "giuseppelillo (via GitHub)" <gi...@apache.org> on 2024/01/31 10:05:57 UTC, 1 replies.

- Re: [PR] KAFKA-15711: KRaft support in LogRecoveryTest [kafka] - posted by "mimaison (via GitHub)" <gi...@apache.org> on 2024/01/31 10:34:45 UTC, 0 replies.

- Re: [PR] KAFKA-15561: Client support for new SubscriptionPattern based subscription [kafka] - posted by "cadonna (via GitHub)" <gi...@apache.org> on 2024/01/31 10:54:39 UTC, 10 replies.

- [jira] [Commented] (KAFKA-16160) AsyncKafkaConsumer is trying to connect to a disconnected node in a tight loop - posted by "Phuc Hong Tran (Jira)" <ji...@apache.org> on 2024/01/31 11:16:00 UTC, 0 replies.

- [PR] Clean-up sticky partitioner code a little bit [kafka] - posted by "myasinkaji (via GitHub)" <gi...@apache.org> on 2024/01/31 12:39:41 UTC, 3 replies.

- Re: [PR] KAFKA-13788: Use AdminClient.incrementalAlterConfigs in ConfigCommand [kafka] - posted by "dengziming (via GitHub)" <gi...@apache.org> on 2024/01/31 13:04:47 UTC, 0 replies.

- Re: [PR] MINOR: Remove unused exceptions [kafka] - posted by "divijvaidya (via GitHub)" <gi...@apache.org> on 2024/01/31 14:31:34 UTC, 2 replies.

- Re: [PR] KAFKA-16066: Upgrade apacheds to 2.0.0.AM27 With apache kerby [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/01/31 15:07:26 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16045) ZkMigrationIntegrationTest.testMigrateTopicDeletion flaky - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/31 15:19:00 UTC, 0 replies.

- [PR] MINOR: Add MetadataType metric from KIP-866 [kafka] - posted by "mumrah (via GitHub)" <gi...@apache.org> on 2024/01/31 15:31:54 UTC, 0 replies.

- [jira] [Commented] (KAFKA-12549) Allow state stores to opt-in transactional support - posted by "highluck (Jira)" <ji...@apache.org> on 2024/01/31 15:36:00 UTC, 0 replies.

- [PR] investigating flaky test [kafka] - posted by "tinaselenge (via GitHub)" <gi...@apache.org> on 2024/01/31 15:50:01 UTC, 0 replies.

- [PR] MINOR: remove un used code [kafka] - posted by "highluck (via GitHub)" <gi...@apache.org> on 2024/01/31 16:02:57 UTC, 0 replies.

- [jira] [Created] (KAFKA-16212) Cache partitions by TopicIdPartition instead of TopicPartition - posted by "Gaurav Narula (Jira)" <ji...@apache.org> on 2024/01/31 16:27:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-16212) Cache partitions by TopicIdPartition instead of TopicPartition - posted by "Omnia Ibrahim (Jira)" <ji...@apache.org> on 2024/01/31 16:46:00 UTC, 0 replies.

- [jira] [Assigned] (KAFKA-15524) Flaky test org.apache.kafka.connect.integration.OffsetsApiIntegrationTest.testResetSinkConnectorOffsetsZombieSinkTasks - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/31 17:39:00 UTC, 0 replies.

- [jira] [Commented] (KAFKA-16212) Cache partitions by TopicIdPartition instead of TopicPartition - posted by "Justine Olshan (Jira)" <ji...@apache.org> on 2024/01/31 17:39:00 UTC, 1 replies.

- [jira] [Assigned] (KAFKA-15917) Flaky test - OffsetsApiIntegrationTest.testAlterSinkConnectorOffsetsZombieSinkTasks - posted by "Chris Egerton (Jira)" <ji...@apache.org> on 2024/01/31 17:39:00 UTC, 0 replies.

- [jira] [Created] (KAFKA-16213) KRaft should honor voterId outside of VotedState - posted by "José Armando García Sancio (Jira)" <ji...@apache.org> on 2024/01/31 17:52:00 UTC, 0 replies.

- [PR] KAFKA-15524, KAFKA-15917: Wait for zombie sink tasks' consumers to commit offsets before trying to modify their offsets in integration tests [kafka] - posted by "C0urante (via GitHub)" <gi...@apache.org> on 2024/01/31 17:56:07 UTC, 0 replies.