apache/kafka issues and pull requests

#15240 - MINOR: Delete KafkaCSVMetricsReporter

Pull Request - State: open - Opened by ijuma 5 months ago

#15239 - streams-scala: remove collections-compat dependency when on Scala 2.13

Pull Request - State: open - Opened by mberndt123 5 months ago - 1 comment
Labels: streams, dependencies

#15239 - streams-scala: remove collections-compat dependency when on Scala 2.13

Pull Request - State: open - Opened by mberndt123 5 months ago - 2 comments
Labels: streams, dependencies

#15238 - KAFKA-16171 Fix hybrid mode controller race

Pull Request - State: closed - Opened by mumrah 5 months ago - 1 comment
Labels: kraft

#15237 - KAFKA-16168; Implement GroupCoordinator.onPartitionsDeleted

Pull Request - State: closed - Opened by dajac 5 months ago - 1 comment
Labels: KIP-848

#15236 - MINOR: Note that Java 11 support for broker and tools is deprecated for removal in 4.0 (KIP-1013)

Pull Request - State: closed - Opened by ijuma 5 months ago

#15236 - MINOR: Note that Java 11 support for broker and tools is deprecated for removal in 4.0 (KIP-1013)

Pull Request - State: closed - Opened by ijuma 5 months ago

#15235 - KAFKA-16144: skip checkQuorum for only 1 voter case

Pull Request - State: closed - Opened by showuon 6 months ago - 4 comments

#15235 - KAFKA-16144: skip checkQuorum for only 1 voter case

Pull Request - State: closed - Opened by showuon 6 months ago - 4 comments

#15234 - KAFKA-15813: Evict client instances from cache (KIP-714)

Pull Request - State: closed - Opened by apoorvmittal10 6 months ago - 6 comments

#15234 - KAFKA-15813: Evict client instances from cache (KIP-714)

Pull Request - State: closed - Opened by apoorvmittal10 6 months ago - 6 comments

#15233 - KAFKA-16166: Generify RetryWithToleranceOperator and ErrorReporter classes

Pull Request - State: closed - Opened by gharris1727 6 months ago - 1 comment
Labels: connect

#15233 - KAFKA-16166: Generify RetryWithToleranceOperator and ErrorReporter classes

Pull Request - State: closed - Opened by gharris1727 6 months ago - 1 comment
Labels: connect

#15232 - KAFKA-16162: [WIP]

Pull Request - State: open - Opened by pprovenzano 6 months ago

#15231 - KAFKA-16164: Pre-Vote, modifying vote RPCs [part 1]

Pull Request - State: open - Opened by ahuang98 6 months ago

#15231 - KAFKA-16164: Pre-Vote, modifying vote RPCs [part 1]

Pull Request - State: open - Opened by ahuang98 6 months ago

#15230 - KAFKA-14616: Fix stray replica of recreated topics in KRaft mode

Pull Request - State: closed - Opened by cmccabe 6 months ago - 5 comments

#15229 - DO NOT MERGE: Isolate Connect tests

Pull Request - State: open - Opened by C0urante 6 months ago
Labels: connect, tests

#15228 - KAFKA-16159: MINOR - Correcting logs to debug telemetry reporter

Pull Request - State: closed - Opened by apoorvmittal10 6 months ago - 4 comments

#15228 - KAFKA-16159: MINOR - Correcting logs to debug telemetry reporter

Pull Request - State: closed - Opened by apoorvmittal10 6 months ago - 4 comments

#15227 - DRAFT: State updater with synchronous remove

Pull Request - State: open - Opened by cadonna 6 months ago

#15225 - KAFKA-15717: Added KRaft support in LeaderEpochIntegrationTest

Pull Request - State: closed - Opened by appchemist 6 months ago - 4 comments

#15224 - KAFKA-15727: Added KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest

Pull Request - State: open - Opened by adixitconfluent 6 months ago - 1 comment

#15224 - KAFKA-15727: Added KRaft support in AlterUserScramCredentialsRequestNotAuthorizedTest

Pull Request - State: open - Opened by adixitconfluent 6 months ago - 1 comment

#15223 - KAFKA-15712: Added KRaft support to MultipleListenersWithSameSecurityProtocolBaseTest

Pull Request - State: open - Opened by smjn 6 months ago

#15223 - KAFKA-15712: Added KRaft support to MultipleListenersWithSameSecurityProtocolBaseTest

Pull Request - State: open - Opened by smjn 6 months ago

#15221 - KAFKA-14505; [8/8] Update offset delete paths

Pull Request - State: closed - Opened by dajac 6 months ago - 5 comments
Labels: KIP-848

#15220 - MINOR: Remove unreachable if-else block in ReplicaManager.scala

Pull Request - State: closed - Opened by drawxy 6 months ago - 7 comments

#15220 - MINOR Remove unreachable if-else block in ReplicaManager.scala

Pull Request - State: open - Opened by drawxy 6 months ago - 4 comments

#15219 - KAFKA-15770: IQv2 must return immutable position

Pull Request - State: open - Opened by mjsax 6 months ago - 1 comment
Labels: streams

#15217 - KAFKA-16141: Fix StreamsStandbyTask system test

Pull Request - State: closed - Opened by mjsax 6 months ago - 7 comments
Labels: streams

#15217 - KAFKA-16141: Fix StreamsStandbyTask system test

Pull Request - State: closed - Opened by mjsax 6 months ago - 7 comments
Labels: streams

#15216 - KAFKA-16115: Adding missing heartbeat metrics

Pull Request - State: open - Opened by philipnee 6 months ago - 4 comments

#15216 - KAFKA-16115: Adding missing heartbeat metrics

Pull Request - State: open - Opened by philipnee 6 months ago

#15215 - KAFKA-16107: Stop fetching while onPartitionsAssign completes

Pull Request - State: closed - Opened by lianetm 6 months ago - 3 comments

#15215 - KAFKA-16107: Stop fetching while onPartitionsAssign completes

Pull Request - State: closed - Opened by lianetm 6 months ago - 3 comments

#15214 - KAFKA-16137: Add missing RPC field descriptions

Pull Request - State: closed - Opened by AndrewJSchofield 6 months ago - 2 comments

#15214 - KAFKA-16137: Add missing RPC field descriptions

Pull Request - State: closed - Opened by AndrewJSchofield 6 months ago - 2 comments

#15213 - KAFKA-16154: Broker returns offset for LATEST_TIERED_TIMESTAMP

Pull Request - State: open - Opened by clolov 6 months ago - 1 comment
Labels: kip, tiered-storage

#15213 - KAFKA-16154: Broker returns offset for LATEST_TIERED_TIMESTAMP

Pull Request - State: open - Opened by clolov 6 months ago - 4 comments
Labels: kip, tiered-storage

#15212 - KAFKA-16147; Partition is assigned to two members at the same time

Pull Request - State: closed - Opened by dajac 6 months ago - 3 comments
Labels: KIP-848

#15212 - KAFKA-16147; Partition is assigned to two members at the same time

Pull Request - State: closed - Opened by dajac 6 months ago - 3 comments
Labels: KIP-848

#15211 - KAFKA-16095: Update list group state type filter to include the states for the new consumer group type

Pull Request - State: open - Opened by DL1231 6 months ago - 5 comments
Labels: KIP-848

#15211 - KAFKA-16095: Update list group state type filter to include the states for the new consumer group type

Pull Request - State: closed - Opened by DL1231 6 months ago - 5 comments
Labels: KIP-848

#15209 - MINOR Removed unused CommittedOffsetsFile class.

Pull Request - State: open - Opened by satishd 6 months ago - 2 comments
Labels: tiered-storage

#15209 - MINOR Removed unused CommittedOffsetsFile class.

Pull Request - State: open - Opened by satishd 6 months ago - 2 comments
Labels: tiered-storage

#15205 - MINOR: populate TopicName in ConsumerGroupDescribe

Pull Request - State: closed - Opened by dongnuo123 6 months ago
Labels: KIP-848

#15202 - KAFKA-16032: Fixes for commit/fetch error handling

Pull Request - State: closed - Opened by lianetm 6 months ago - 2 comments

#15196 - MINOR: Uniformize error handling/transformation in GroupCoordinatorService

Pull Request - State: closed - Opened by dajac 6 months ago - 3 comments
Labels: KIP-848

#15196 - MINOR: Uniformize error handling/transformation in GroupCoordinatorService

Pull Request - State: open - Opened by dajac 6 months ago - 2 comments
Labels: KIP-848

#15193 - KAFKA-16101: KRaft migration documentation is incorrect

Pull Request - State: open - Opened by cmccabe 6 months ago - 7 comments
Labels: kraft

#15193 - KAFKA-16101: KRaft migration documentation is incorrect

Pull Request - State: closed - Opened by cmccabe 6 months ago - 10 comments
Labels: kraft

#15190 - KAFKA-15811: Enhance request context with client socket port information (KIP-714)

Pull Request - State: closed - Opened by apoorvmittal10 6 months ago - 4 comments

#15189 - KAFKA-16123: Fix KStreamKStreamJoinProcessor forwards null records for left/outer joins unconditionally of the join window.

Pull Request - State: open - Opened by florin-akermann 6 months ago
Labels: streams

#15188 - KAFKA-15561: Client support for new SubscriptionPattern based subscription

Pull Request - State: open - Opened by Phuc-Hong-Tran 6 months ago - 16 comments
Labels: consumer, ctr

#15186 - KAFKA-16029: Fix "Unable to find FetchSessionHandler for node X" bug

Pull Request - State: closed - Opened by kirktrue 6 months ago - 8 comments

#15186 - KAFKA-16029: Fix "Unable to find FetchSessionHandler for node X" bug

Pull Request - State: closed - Opened by kirktrue 6 months ago - 9 comments

#15183 - KAFKA-14505; [7/N] Always materialize the most recent committed offset

Pull Request - State: closed - Opened by dajac 6 months ago - 6 comments
Labels: KIP-848

#15183 - KAFKA-14505; [7/N] Always materialize the most recent committed offset

Pull Request - State: closed - Opened by dajac 6 months ago - 6 comments
Labels: KIP-848

#15181 - [KAFKA-15749] Adding support for Kraft in test testClusterIdPresent

Pull Request - State: open - Opened by chirag-wadhwa5 6 months ago

#15180 - KAFKA-15575: Begin enforcing 'tasks.max' property for connectors

Pull Request - State: closed - Opened by C0urante 6 months ago - 3 comments
Labels: connect, kip

#15178 - MINOR: Change Connect integration StopStartLatch::await to throw TimeoutException on timeout

Pull Request - State: closed - Opened by C0urante 6 months ago - 1 comment
Labels: connect, tests

#15176 - KAFKA-14505; [6/N] Avoid recheduling callback in request thread

Pull Request - State: closed - Opened by dajac 6 months ago - 3 comments
Labels: KIP-848

#15175 - KAFKA-15751: KRaft support in BaseAdminIntegrationTest

Pull Request - State: open - Opened by tinaselenge 6 months ago - 2 comments

#15167 - KAFKA-15853: Move AuthorizerUtils and its dependencies to server module

Pull Request - State: open - Opened by OmniaGM 6 months ago

#15167 - KAFKA-15853: Move AuthorizerUtils and its dependencies to server module

Pull Request - State: closed - Opened by OmniaGM 6 months ago - 4 comments

#15164 - KAFKA-15853: Move PasswordEncoder to server module

Pull Request - State: open - Opened by OmniaGM 6 months ago - 1 comment

#15164 - KAFKA-15853: Move PasswordEncoder to server module

Pull Request - State: closed - Opened by OmniaGM 6 months ago - 1 comment

#15162 - KAFKA-14404: fix overlap of streams-config sections & describe additional parameters

Pull Request - State: closed - Opened by AyoubOm 6 months ago - 5 comments

#15158 - KAFKA-15853: Move KafkaConfig.Defaults to server module

Pull Request - State: closed - Opened by OmniaGM 6 months ago - 5 comments

#15152 - KAFKA-15460: Add group type filter to List Groups API

Pull Request - State: open - Opened by rreddy-22 6 months ago - 1 comment
Labels: KIP-848

#15152 - KAFKA-15460: Add group type filter to List Groups API

Pull Request - State: open - Opened by rreddy-22 6 months ago
Labels: KIP-848

#15151 - KAFKA-15594: Add version 3.6 to Kafka Streams system tests

Pull Request - State: closed - Opened by mjsax 6 months ago - 9 comments
Labels: streams, tests

#15150 - KAFKA-15462: Add Group Type Filter for List Group to the Admin Client

Pull Request - State: open - Opened by rreddy-22 6 months ago
Labels: KIP-848

#15150 - KAFKA-15462: Add Group Type Filter for List Group to the Admin Client

Pull Request - State: open - Opened by rreddy-22 6 months ago - 1 comment
Labels: KIP-848

#15147 - KAFKA-7957: Enable testMetricsReporterUpdate

Pull Request - State: closed - Opened by mimaison 6 months ago - 2 comments
Labels: tests

#15147 - KAFKA-7957: Enable testMetricsReporterUpdate

Pull Request - State: closed - Opened by mimaison 6 months ago - 2 comments
Labels: tests

#15141 - KAFKA-16073: [Tiered] Update localLogStartOffset before deleting segments in memory t…

Pull Request - State: open - Opened by hzh0425 6 months ago - 2 comments
Labels: tiered-storage

#15141 - KAFKA-16073: [Tiered] Update localLogStartOffset before deleting segments in memory t…

Pull Request - State: open - Opened by hzh0425 6 months ago - 2 comments
Labels: tiered-storage

#15139 - KAFKA-15468 [1/2]: Prevent transaction coordinator reloads on already loaded leaders

Pull Request - State: closed - Opened by jolshan 6 months ago
Labels: kraft

#15139 - KAFKA-15468 [1/2]: Prevent transaction coordinator reloads on already loaded leaders

Pull Request - State: closed - Opened by jolshan 6 months ago
Labels: kraft

#15137 - KAFKA-14412: Transactional StateStores

Pull Request - State: open - Opened by nicktelford 6 months ago - 5 comments

#15137 - KAFKA-14412: Transactional StateStores

Pull Request - State: open - Opened by nicktelford 6 months ago - 6 comments

#15136 - KAFKA-16082: Avoid resuming future replica if current replica is in the same directory

Pull Request - State: open - Opened by gaurav-narula 6 months ago - 2 comments

#15133 - KAFKA-16085: Add metric value consolidated for topics on a broker for tiered storage.

Pull Request - State: closed - Opened by showuon 6 months ago - 11 comments
Labels: tiered-storage

#15133 - KAFKA-16085: Add metric value consolidated for topics on a broker for tiered storage.

Pull Request - State: open - Opened by showuon 6 months ago - 11 comments
Labels: tiered-storage

#15121 - KAFKA-16055: Thread unsafe use of HashMap stored in QueryableStoreProvider#storeProviders

Pull Request - State: closed - Opened by nuzayats 6 months ago - 2 comments
Labels: streams

#15109 - MINOR: Enable Gradle Remote Build Cache

Pull Request - State: open - Opened by nicktelford 6 months ago - 9 comments

#15103 - KAFKA-15853: Move KafkaConfig to server module

Pull Request - State: open - Opened by OmniaGM 6 months ago - 6 comments

#15101 - KAFKA-16072: JUnit 5 extension to detect thread leak

Pull Request - State: open - Opened by wernerdv 6 months ago - 8 comments
Labels: tests

#15092 - KAFKA-16067 Refactoring ConsumerGroupListing + add test

Pull Request - State: open - Opened by rykovsi 6 months ago - 1 comment

#15087 - KAFKA-15987: Refactor ReplicaManager code for transaction verification

Pull Request - State: closed - Opened by jolshan 6 months ago

#15085 - KAFKA-16042: Add byte-rate metrics for topic and partition

Pull Request - State: open - Opened by afshing 6 months ago - 4 comments
Labels: stale

#15085 - KAFKA-16042: Add byte-rate metrics for topic and partition

Pull Request - State: open - Opened by afshing 6 months ago - 4 comments
Labels: stale

#15078 - KAFKA-16047: Leverage the fenceProducers timeout in the InitProducerId

Pull Request - State: open - Opened by akaltsikis 6 months ago - 2 comments

#15065 - MINOR: set test global timeout as 10 mins

Pull Request - State: open - Opened by showuon 6 months ago - 4 comments

#15052 - [WIP] MINOR: fix flaky test

Pull Request - State: open - Opened by showuon 7 months ago

#15052 - [WIP] MINOR: fix flaky test

Pull Request - State: open - Opened by showuon 7 months ago

#15051 - Update Streams API broker compat table for AK 3.7

Pull Request - State: closed - Opened by JimGalasyn 7 months ago - 1 comment
Labels: streams, docs

#15028 - KAFKA-15747: KRaft support in DynamicConnectionQuotaTest

Pull Request - State: closed - Opened by phong260702 7 months ago - 5 comments
Labels: tests

GitHub / apache/kafka issues and pull requests