Skip to content

/ kafka

New pull request New
769 Open 8,482 Closed
769 Open 8,482 Closed
Author
Filter by author
Label
Filter by label
Use alt + click/return to exclude labels.
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
👍 👎 😄 🎉 😕 ❤️ 🚀 👀
KAFKA-10366 & KAFKA-9649: Implement KIP-659 to allow TimeWindowedDeserializer and TimeWindowedSerde to handle window size
#9253 opened Sep 4, 2020 by lct45 0 of 3
KAFKA-10241: Add test for message compatibility
#9252 opened Sep 4, 2020 by tombentley
1
KAFKA-10459: Document IQ APIs where order does not hold between stores
#9251 opened Sep 4, 2020 by showuon 0 of 3
1
KAFKA-10461 The config of closing heartbeat is invalid.
#9250 opened Sep 4, 2020 by jiweiautohome
KAFKA-10458: Add update quota for TokenBucket registered with Sensor
#9249 opened Sep 3, 2020 by apovzner 0 of 3
1
KAFKA-10362: When resuming Streams active task with EOS, the checkpoint file is deleted
streams
#9247 opened Sep 2, 2020 by DOJI45 0 of 3
Minor: publish static analysis reports in PR builds
#9246 opened Sep 2, 2020 by mumrah
2
Consolidate duplicated logic on reset tools
streams tools
#9244 opened Sep 2, 2020 by manijndl7 0 of 3
2
Add ConsumerGroupCommand to delete static members
#9243 opened Sep 2, 2020 by sndp2693 0 of 3
MINOR: Fix misleading doc for replication quota
#9242 opened Sep 2, 2020 by ocadaruma 0 of 3
MINOR: Update the javadoc in GroupMetadataManager.scala
#9241 opened Sep 2, 2020 by showuon 0 of 3
2
Adding reverse iterator usage for sliding windows processing (extending KIP-450)
#9239 opened Sep 1, 2020 by lct45 0 of 3
17
KAFKA-10454 / integration test streams
#9237 opened Sep 1, 2020 by lkokhreidze 0 of 3
MINOR: Log warn message with details when there's kerberos login issue
#9236 opened Sep 1, 2020 by cnZach 0 of 3
6
KAFKA-10449: Add some important parameter desc in connect-distributed.properties
#9235 opened Aug 31, 2020 by tinawenqiao 0 of 3
1
KAFKA-10447: Migrate tools module to JUnit 5 and mockito
#9231 opened Aug 30, 2020 by ijuma 0 of 3
1
KAFKA-10446 add lz4 and zstd to compression type of benchmark_test.py
#9230 opened Aug 30, 2020 by chia7712 0 of 3
MINOR: Reduce allocations in requests via buffer caching
#9229 opened Aug 29, 2020 by ijuma • Draft 0 of 3
6
KAFKA-10445: Align IQ SessionStore API with Instant-based methods as ReadOnlyWindowStore
#9228 opened Aug 29, 2020 by jeqo • Draft 0 of 3
KAFKA-10439: Connect's Values to parse BigInteger as Decimal with zero scale.
#9227 opened Aug 27, 2020 by avocader 0 of 3
KAFKA-10431: Sequential selection of payload in ProducerPerformance
#9225 opened Aug 27, 2020 by huxihx 0 of 3
1
improve MM2 unit tests
#9224 opened Aug 26, 2020 by ning2008wisc
KAFKA-10438 Lazy initialization of record header to reduce memory usa…
#9223 opened Aug 26, 2020 by chia7712 0 of 3
5
KAFKA-10437: Implement test-utils and StateStore changes for KIP-478
streams
#9222 opened Aug 26, 2020 by vvcephei 0 of 3
27
KAFKA-10436: Implement KIP-478 Topology changes
streams
#9221 opened Aug 26, 2020 by vvcephei 0 of 3
35
ProTip! Filter pull requests by the default branch with base:trunk.
You can’t perform that action at this time.