Skip to content

Pull requests: apache/kafka

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

Pull requests list

MINOR: remove onChange call in stream assignor assign method
#13034 opened Dec 21, 2022 by lihaosky Loading…
3 tasks
KAFKA-14538: Implement KRaft metadata transactions
#13033 opened Dec 21, 2022 by cmccabe Loading…
7
KAFKA-14540: Fix DataOutputStreamWritable#writeByteBuffer
#13032 opened Dec 21, 2022 by michaeljmarshall Loading…
3 tasks
8
MINOR: increase connectionMaxIdleMs to make test reliable
#13031 opened Dec 21, 2022 by showuon Loading…
3 tasks
2
MINOR; Add log message when Log high watermark differs
#13030 opened Dec 21, 2022 by jsancio Loading…
3 tasks
1
MINOR: Add zk migration field to the ApiVersionsResponse
#13029 opened Dec 20, 2022 by akhileshchg Loading…
3
KAFKA-14458: Introduce RPC support during ZK migration
#13028 opened Dec 20, 2022 by akhileshchg Loading…
9
MINOR Send ZK broker epoch in registration
#13027 opened Dec 20, 2022 by mumrah Loading…
1
KAFKA-14299: Make sure no progress is made on paused topologies
#13025 opened Dec 20, 2022 by lucasbru Loading…
3 tasks done
3
MINOR: fix expected version in streams upgrade test
streams tests Test fixes (including flaky tests)
#13022 opened Dec 19, 2022 by mjsax Loading…
3 tasks
6
KAFKA-14468: Implement CommitRequestManager to manage the commit and autocommit requests
#13021 opened Dec 19, 2022 by philipnee Loading…
3 tasks
5
KAFKA-14530: Check state updater more often
#13017 opened Dec 19, 2022 by lucasbru Loading…
3 tasks done
5
KAFKA-14477: Move LogValidator and related to storage module
#13012 opened Dec 17, 2022 by ijuma Loading…
3 tasks
6
[WIP] KAFKA-14498: investigate flaky
#13004 opened Dec 16, 2022 by showuon Loading…
3 tasks
MINOR: only allow certain operations when in KRaft premigration
#13003 opened Dec 16, 2022 by cmccabe Loading…
[REVERT] Kip-837
#12999 opened Dec 15, 2022 by vamossagar12 Loading…
KAFKA-14493: Introduce Zk to KRaft migration state machine STUBs in KRaft controller.
#12998 opened Dec 15, 2022 by akhileshchg • Draft
2
KAFKA-14492: Extract a method to create LogManager, in order to be overrided by subclass of KafkaServer
#12997 opened Dec 15, 2022 by PhantomMaa Loading…
4
KAFKA-14396: De-flake memory tests with new TestUtils.restrictMemory
#12995 opened Dec 15, 2022 by gharris1727 • Draft
3 tasks
3
KIP-887: Add ConfigProvider to make use of environment variables
#12992 opened Dec 14, 2022 by Schm1tz1 Loading…
3 tasks
KAFKA-14451: Rack-aware consumer partition assignment for RangeAssignor (KIP-881)
#12990 opened Dec 14, 2022 by rajinisivaram Loading…
3 tasks
KAFKA-14405: Log a warning when users attempt to set a config controlled by Streams
#12988 opened Dec 14, 2022 by ashmeet13 Loading…
3 tasks
2
KAFKA-14455: Kafka Connect create and update REST APIs should surface failures while writing to the config topic
connect
#12984 opened Dec 13, 2022 by yashmayya Loading…
3 tasks
8
KAFKA-14464: Make resource leaks for MM2 resources more difficult
mirror-maker-2
#12980 opened Dec 12, 2022 by gharris1727 • Draft
3 tasks
KAFKA-14544 The "is-future" should be removed from metrics tags after future log becomes current log
#12979 opened Dec 12, 2022 by chia7712 Loading…
3 tasks
2
ProTip! Mix and match filters to narrow down what you’re looking for.