Skip to content

Pull requests: apache/kafka

New pull request New
509 Open 22,620 Closed
509 Open 22,620 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

MINOR: Assert RequestConvertToJsonTest metrics against literal values core Kafka Broker small Small PRs tests Test fixes (including flaky tests) triage PRs from the community
#23218 opened Aug 20, 2026 by Parkerhiphop Contributor Loading…
MINOR: Fix fetch snapshot RPC topic partition check (#23185)
#23217 opened Aug 20, 2026 by kevin-wu24 Contributor Loading…
MINOR: Fix fetch snapshot RPC topic partition check (#23185)
#23216 opened Aug 20, 2026 by kevin-wu24 Contributor Loading…
MINOR: Fix fetch snapshot RPC topic partition check (#23185)
#23215 opened Aug 20, 2026 by kevin-wu24 Contributor Loading…
KAFKA-20939 Mark "bootstrap.resolve.timeout.ms" as an experimental feature clients small Small PRs triage PRs from the community
#23214 opened Aug 20, 2026 by m1a2st Collaborator Loading…
2
KAFKA-16235: Skip deleted-topic auto-commit retries before rebalance clients consumer triage PRs from the community
#23213 opened Aug 20, 2026 by MdTanwer Loading…
KAFKA-20968: Connect retry backoff overflows with infinite retries, dropping the delay to zero and restarting the exponential ramp connect small Small PRs triage PRs from the community
#23212 opened Aug 20, 2026 by SEPURI-SAI-KRISHNA Contributor Loading…
KAFKA-20967: RemoteLogManager.read() leaks the remote segment InputStream when reading a batch fails small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#23211 opened Aug 20, 2026 by SEPURI-SAI-KRISHNA Contributor Loading…
1
KAFKA-20845: Don't flush empty batch when appending large records in group coordinator (4.0)
#23209 opened Aug 20, 2026 by dajac Member Loading…
KAFKA-20845: Don't flush empty batch when appending large records in group coordinator (4.1)
#23208 opened Aug 20, 2026 by dajac Member Loading…
KAFKA-20845: Don't flush empty batch when appending large records in group coordinator (4.2)
#23207 opened Aug 20, 2026 by dajac Member Loading…
KAFKA-20966: RemoteLogInputStream can attempt an unbounded memory allocation when reading a corrupted remote log segment clients small Small PRs storage Pull requests that target the storage module tiered-storage Related to the Tiered Storage feature triage PRs from the community
#23206 opened Aug 20, 2026 by SEPURI-SAI-KRISHNA Contributor Loading…
KAFKA-20961: Carry leader epoch history over when replacing the current log with the future log core Kafka Broker storage Pull requests that target the storage module triage PRs from the community
#23205 opened Aug 20, 2026 by haung921209 Loading…
KAFKA-20785: Return INVALID_PRODUCER_EPOCH when EndTxn commit races with coordinator-side abort core Kafka Broker small Small PRs triage PRs from the community
#23204 opened Aug 20, 2026 by suzhiking Contributor Loading…
KAFKA-20917: Reduce per-partition and per-batch overhead in RecordAccumulator.ready() clients performance producer triage PRs from the community
#23203 opened Aug 20, 2026 by eeriee Contributor Loading…
KAFKA-20965: Remove hamcrest from org.apache.kafka.streams.state.internals.metrics package small Small PRs streams tests Test fixes (including flaky tests)
#23201 opened Aug 19, 2026 by korih Loading…
1
KAFKA-20963: Remove hamcrest from org.apache.kafka.streams.processor small Small PRs streams tests Test fixes (including flaky tests) triage PRs from the community
#23200 opened Aug 19, 2026 by harmadasg Contributor Loading…
KAFKA-20962: Remove hamcrest from org.apache.kafka.streams.kstream.internals.suppress package streams tests Test fixes (including flaky tests) triage PRs from the community
#23199 opened Aug 19, 2026 by harmadasg Contributor Loading…
mm2-fail-fast-offset-loss connect mirror-maker-2 triage PRs from the community
#23198 opened Aug 19, 2026 by Shivani1502 Loading…
KAFKA-19042 Rewrite SaslMultiMechanismConsumerTest, SaslSslConsumerTest, SslConsumerTest to Java clients core Kafka Broker tests Test fixes (including flaky tests) triage PRs from the community
#23197 opened Aug 19, 2026 by m1a2st Collaborator Loading…
MINOR: Fix typos in Streams configuration docs docs small Small PRs triage PRs from the community
#23195 opened Aug 18, 2026 by arcabotai Loading…
3 tasks done
2
MINOR: gradle-versions-plugin reference has been moved from build.gradle to settings.gradle build Gradle build or GitHub Actions small Small PRs triage PRs from the community
#23193 opened Aug 18, 2026 by dejan2609 Contributor Loading…
1
KAFKA-20956: Remove hamcrest from org.apache.kafka.streams.examples package build Gradle build or GitHub Actions ci-approved streams
#23192 opened Aug 18, 2026 by majialoong Contributor Loading…
1
KAFKA-20942: Refactor empty catch blocks in clients module tests to use assertThrows ci-approved clients consumer producer tests Test fixes (including flaky tests) triage PRs from the community
#23187 opened Aug 18, 2026 by kapilhadoltikar Loading…
KAFKA-19629: Deadlock in Kafka Streams when processing Interactive Queries and state store updates concurrently streams
#23184 opened Aug 17, 2026 by gabriellefu Contributor Loading…
8
ProTip! Type g i on any issue or pull request to go back to the issue listing page.