Skip to content

Pull requests: apache/kafka

New pull request New
1,001 Open 11,541 Closed
1,001 Open 11,541 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
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

KAFKA-14098: Add meaningful default client IDs for Connect workers
#12544 opened Aug 20, 2022 by C0urante Loading…
2
KAFKA-10149: Allow auto preferred leader election for partitions are not being reassigned
#12543 opened Aug 19, 2022 by songnon Loading…
3 tasks
3
MINOR: Fix locking in GroupMetadataManager's metrics
#12542 opened Aug 19, 2022 by dajac Loading…
3 tasks
1
MINOR: reduce Metadata log volume when last seen epoch is not updated
#12541 opened Aug 19, 2022 by fabien-chebel Loading…
3 tasks
3
bug: State stores loose state when tasks are reassigned under EOS wit…
#12540 opened Aug 19, 2022 by chorslev Loading…
MINOR: Modify the error log level in SaslChannelBuilder
#12539 opened Aug 19, 2022 by RivenSun2 Loading…
3 tasks
1
KAFKA-14160: Streamline clusterId retrieval in Connect
#12536 opened Aug 18, 2022 by mimaison Loading…
3 tasks
2
MINOR; Use underscore for variable initialization in Scala sources
#12534 opened Aug 18, 2022 by mdedetrich Loading…
5
Add new metadata loader and publisher [WIP]
#12531 opened Aug 17, 2022 by cmccabe Loading…
Add leader count checks to StripedReplicaPlacerTest
#12529 opened Aug 17, 2022 by ahuang98 • Draft
3 tasks
MINOR: don't record the throttled rate when there is no throttled par…
#12528 opened Aug 17, 2022 by chia7712 Loading…
3 tasks
KAFKA-14133: Replace EasyMock with Mockito in streams tests
#12527 opened Aug 17, 2022 by clolov Loading…
4
KAFKA-14133: Replace EasyMock with Mockito in streams test
#12524 opened Aug 17, 2022 by mdedetrich Loading…
4
[WIP] KAFKA-10199: Handle exceptions from state updater
streams
#12519 opened Aug 16, 2022 by guozhangwang Loading…
3 tasks
1
KAFKA-14151: validate offsets of input records before writing them file
#12516 opened Aug 15, 2022 by vincent81jiang • Draft
3 tasks
3
MINOR: some fixes to the KRaft bootstrap logic
#12513 opened Aug 14, 2022 by cmccabe Loading…
48
KAFKA-14138: Wrapping all non-fatal exceptions in KafkaException and throwing all fata exceptions directly for producer.send()
#12512 opened Aug 13, 2022 by vamossagar12 Loading…
4
KAFKA-14133: Replace EasyMock with Mockito in WorkerCoordinatorTest and RootResourceTest
#12509 opened Aug 12, 2022 by yashmayya Loading…
5
KAFKA-14133: Replace EasyMock with Mockito in streams tests
#12505 opened Aug 11, 2022 by clolov Loading…
22
KAFKA-14149: Fix DynamicBrokerReconfigurationTest in 3.2
#12504 opened Aug 11, 2022 by mimaison • Draft
KAFKA-14162: HoistField SMT should not return an immutable map for schemaless key/value
connect
#12502 opened Aug 11, 2022 by yashmayya Loading…
12
KAFKA-14097: Separate configuration for producer ID expiry
#12501 opened Aug 10, 2022 by jolshan Loading…
3 tasks
39
MINOR: Update site docs for ASF compliance
#12494 opened Aug 8, 2022 by bbejeck Loading…
3 tasks
6
MINOR: Migrate from slf4j-log4j12 to slf4j-reload4j.
#12493 opened Aug 8, 2022 by rigelbm Loading…
3 tasks
KAFKA-14133: Replace EasyMock with Mockito in streams tests
#12492 opened Aug 8, 2022 by clolov Loading…
35
ProTip! Filter pull requests by the default branch with base:trunk.