KIPs Under Discussion

Last Updated: 2022/08/24 08:08:33 UTC

KIP Description Status +1 0 -1 Created by Age
863 Reduce Fetcher#parseRecord() memory copy 0 0 0 LinShunKang 2 days
861 Add BytesIn/BytesOut per listener metrics 0 0 0 Luke Chen 3 weeks
860 Add client-provided option to guard against replication factor change during partition reassignments 0 0 0 Stanislav Kozlovski 4 weeks
859 Add Metadata Log Processing Error Related Metrics
2 Colin McCabe
=?UTF-8?Q?Jos=C3=A9_Armando_Garc=C3=ADa_Sancio?=
0 0 Niket Goel 4 weeks
858 Handle JBOD broker disk failure in KRaft 0 0 0 Igor Soarez 4 weeks
857 Streaming recursion in Kafka Streams 0 0 0 Nicholas Telford 4 weeks
856 KRaft Disk Failure Recovery 0 0 0 José Armando García Sancio 4 weeks
855 Add schema.namespace parameter to SetSchemaMetadata SMT in Kafka Connect 0 0 0 Michael Negodaev 5 weeks
854 Separate configuration for producer ID expiry
3 Jason Gustafson
Tom Bentley
David Jacot
0 0 Justine Olshan 5 weeks
853 KRaft Voter Changes 0 0 0 José Armando García Sancio 5 weeks
852 Optimize calculation of size for log in remote tier 0 0 0 Divij Vaidya 8 weeks
849 Expose logdirs total and usable space via kafka-log-dirs.sh 0 0 0 dengziming 9 weeks
848 The Next Generation of the Consumer Rebalance Protocol 0 0 0 David Jacot 10 weeks
847 Add ProducerCount metrics
1 Ismael Juma
0 0 Artem Livshits 10 weeks
846 Processor-level Streams metrics for records/bytes Produced
1 Sophie Blee-Goldman
0 0 A. Sophie Blee-Goldman 12 weeks
845 'HasField' predicate for kafka connect 0 0 0 Kumud Kumar Srivatsava Tirupati 13 weeks
844 Transactional State Stores 0 0 0 Alex Sorokoumov 13 weeks
843 Adding getMetricOrElseCreate method to Metrics
1 John Roesler
0 0 Sagar Rao 13 weeks
842 Add richer group offset reset mechanisms 0 0 0 hudeqi 13 weeks
841 Fenced replicas should not be allowed to join the ISR in KRaft
3 David Arthur
Colin McCabe
David Jacot
0 0 David Jacot 14 weeks
840 Config file option for MessageReader/MessageFormatter in ConsoleProducer/ConsoleConsumer
1 John Roesler
0 0 Alexandre Garnier 14 weeks
839 Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams 0 0 0 Francois Rosiere 14 weeks
836 Addition of Information in DescribeQuorumResponse about Voter Lag
2 Guozhang Wang
David Arthur
0 0 Niket Goel 16 weeks
835 Monitor KRaft Controller Quorum Health 0 0 0 Jose Armando Garcia Sancio 16 weeks
834 Pause / Resume KafkaStreams Topologies
4 Guozhang Wang
Leah Thomas
Sophie Blee-Goldman
John Roesler
0 0 Jim Hughes 16 weeks
833 Mark KRaft as Production Ready
5 Bill Bejeck
Jason Gustafson
=?UTF-8?Q?Jos=C3=A9_Armando_Garc=C3=ADa_Sancio?=
Colin McCabe
Ismael Juma
0 0 Colin McCabe 16 weeks
832 Allow creating a producer/consumer using a producer/consumer config 0 0 0 Francois Rosiere 16 weeks
831 Add metric for log recovery progress
3 Jun Rao
Tom Bentley
Luke Chen
0 0 Luke Chen 18 weeks
830 Allow disabling JMX Reporter
3 Tom Bentley
Mickael Maison
Ismael Juma
0 0 Mickael Maison 19 weeks
829 (console-consumer) add print.topic property 0 0 0 Evans Jahja 19 weeks
828 Add the corresponding validator to the configuration where the validator is missing 0 0 0 RivenSun 20 weeks
827 Expose logdirs total and usable space via Kafka API
3 Tom Bentley
Mickael Maison
John Roesler
0 0 Mickael Maison 20 weeks
826 Define platforms supported 0 0 0 Mickael Maison 21 weeks
823 Update Admin::describeConfigs to allow fetching specific configurations 0 0 0 Vikas Singh 26 weeks
822 Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols 0 0 0 RivenSun 27 weeks
821 Connect Transforms support for nested structures
2 Chris Egerton
John Roesler
0 0 Jorge Esteban Quilcate Otoya 28 weeks
819 Merge multiple KStreams in one operation 0 0 0 Nicholas Telford 29 weeks
818 Introduce cache-size-bytes-total Task Level Metric 0 0 0 Sagar Rao 29 weeks
817 Fix inconsistency in dynamic application log levels 0 0 0 Dongjin Lee 30 weeks
816 Topology changes without local state reset 0 0 0 Nicholas Telford 30 weeks
809 Support live upgrades with dynamic addition/removal of modular topologies 0 0 0 A. Sophie Blee-Goldman 36 weeks
807 Refactor KafkaStreams exposed metadata hierarchy 0 0 0 Josep Prat 38 weeks
804 OfflinePartitionsCount Tagged by Topic 0 0 0 Mason Joseph Legere 39 weeks
803 Add Task ID and Connector Name to Connect Task Context 0 0 0 Sarah Story 39 weeks
802 Validation Support for Kafka Connect SMT and Converter Options 0 0 0 Gunnar Morling 39 weeks
799 Align behaviour for producer callbacks with documented behaviour
1 John Roesler
0 0 Seamus O Ceanainn 41 weeks
798 Add possibility to write kafka headers in Kafka Console Producer
2 David Jacot
John Roesler
0 0 Florin Akermann 41 weeks
797 Accept duplicate listener on port for IPv4/IPv6
3 Matthew Benedict de Detrich
Tom Bentley
Luke Chen
0 0 Matthew de Detrich 41 weeks
795 Add public APIs for AbstractCoordinator 0 0 0 Hector Geraldino 42 weeks
793 Sink Connectors: Support topic-mutating SMTs for async connectors (preCommit users) 0 0 0 Diego Erdody 42 weeks
787 MM2 Interface to manage Kafka resources 0 0 0 Omnia Ibrahim 43 weeks
786 Emit Metric Client Quota Values 0 0 0 Mason Joseph Legere 44 weeks
785 Automatic storage formatting 0 0 0 Igor Soarez 44 weeks
782 Expandable batch size in producer 0 0 0 Luke Chen 44 weeks
781 Improve MirrorMaker2's client configuration 0 0 0 Dongjin Lee 45 weeks
780 Support fine-grained compression options 0 0 0 Dongjin Lee 45 weeks
777 Improved testability for Admin client 0 0 0 Tom Bentley 48 weeks
776 Add Consumer#peek for debugging/tuning 0 0 0 Luke Chen 48 weeks
774 Deprecate public access to Admin client's *Result constructors
1 Josep Prat
0 0 Tom Bentley 50 weeks
772 Encrypt KRaft Metadata Secrets at Rest 0 0 0 Colin McCabe 51 weeks
767 Connect Latency Metrics 0 0 0 Jordan Bull 1 years 2 weeks
765 Introduce new SlidingWindow type for [start,end] time 0 0 0 Luke Chen 1 years 5 weeks
762 Delete Committed Connect Records 0 0 0 Ryanne Dolan 1 years 6 weeks
760 Minimum value for segment.ms and segment.bytes 0 0 0 Badai Aqrandista 1 years 7 weeks
759 Unneeded repartition canceling 0 0 0 Ivan Ponomarev 1 years 9 weeks
758 Remove list of latest producer append information for broker 0 0 0 Yi Ding 1 years 9 weeks
756 Move StreamsResetter tool outside of core 0 0 0 Jorge Esteban Quilcate Otoya 1 years 11 weeks
755 Add new AUTO_CREATE ACL for auto topic creation 0 0 0 Christopher L. Shannon 1 years 11 weeks
754 Make Scala case class's final 0 0 0 Matthew de Detrich 1 years 11 weeks
753 ACL authentication, Host field support IP network segment 0 0 0 loboxu 1 years 11 weeks
752 Support --bootstrap-server in ReplicaVerificationTool
1 Dongjin Lee
0 0 Dongjin Lee 1 years 11 weeks
749 Add --files and --file-separator options to the ConsoleProducer
2 Boyang Chen
wenbing shen
0 0 Wenbing Shen 1 years 12 weeks
743 Remove config value 0.10.0-2.4 of Streams built-in metrics version config
1 Bruno Cadonna
0 0 Bruno Cadonna 1 years 14 weeks
739 Block Less on KafkaProducer#send 0 0 0 Moses Nakamura 1 years 15 weeks
737 Add canTrackSource to ReplicationPolicy 0 0 0 Matthew de Detrich 1 years 15 weeks
736 Report the true end to end fetch latency 0 0 0 Ming Liu 1 years 17 weeks
731 Record Rate Limiting for Kafka Connect 0 0 0 Ryanne Dolan 1 years 20 weeks
729 Custom validation of records on the broker prior to log append 0 0 0 Soumyajit Sahu 1 years 21 weeks
728 Introduce the RESTORING state to the KafkaStreams state machine 0 0 0 A. Sophie Blee-Goldman 1 years 21 weeks
727 Add --under-preferred-replica-partitions option to describe topics command
1 Tom Bentley
0 0 Wenbing Shen 1 years 22 weeks
723 Add socket.tcp.no.delay property to Kafka Config 0 0 0 Andrei Iatsuk 1 years 23 weeks
718 Make KTable Join on Foreign key unopinionated
2 Guozhang Wang
John Roesler
0 0 Marco Lotz 1 years 25 weeks
714 Client metrics and observability 0 0
1 Magnus Edenhill
Magnus Edenhill 1 years 28 weeks
713 Validation of Enums in configuration 0 0 0 Jeremy Custenborder 1 years 29 weeks
712 Shallow Mirroring 0 0 0 Henry Cai 1 years 29 weeks
710 Full support for distributed mode in dedicated MirrorMaker 2.0 clusters 0 0 0 Daniel Urban 1 years 30 weeks
706 Add method "Producer#send" to return CompletionStage instead of Future 0 0 0 Ismael Juma 3 years 31 weeks
705 Selectively Disable Topology Optimizations 0 0 0 Almog Gavra 1 years 32 weeks
703 Add a metrics for reporting idle connections closed 0 0 0 Pere Urbon 1 years 33 weeks
702 The control plane needs to force the validation of requests from the controller 0 0 0 Wenbing Shen 1 years 33 weeks
701 Add--override option to bin/connect-distributed.sh 0 0 0 Akitoshi Yoshida 1 years 35 weeks
697 Stricter parsing of addresses in configs 0 0 0 Tom Bentley 1 years 37 weeks
694 Support Reducing Partitions for Topics 0 0 0 George Shu 1 years 38 weeks
693 Client-side Circuit Breaker for Partition Write Errors 0 0 0 George Shu 1 years 38 weeks
692 Make AdminClient value object constructors public 0 0 0 Noa Resare 1 years 38 weeks
688 Support dynamic update of delete.topic.enable config 0 0 0 Prateek Agarwal 1 years 39 weeks
686 API to ensure Records policy on the broker 0 0 0 Nikolay Izhikov 1 years 40 weeks
685 Loosen permission for listing reassignments 0 0 0 David Jacot 1 years 41 weeks
683 Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSON string 0 0 0 Joshua Grisham 1 years 41 weeks
682 Connect TimestampConverter support for multiple fields and multiple input formats 0 0 0 Joshua Grisham 1 years 42 weeks
681 Rename master key in delegation token feature 0 0 0 Tom Bentley 1 years 42 weeks
675 Convert KTable to a KStream using the previous value 0 0 0 Javier Freire Riobó 1 years 46 weeks
674 Metric Reporter to Aggregate Metrics in Kafka Streams 0 0 0 Bruno Cadonna 1 years 47 weeks
672 Introduce Kafka Streams Specific Uncaught Exception Handler 0 0 0 Walker Carlson 1 years 49 weeks
670 Add ConsumerGroupCommand to delete static members 0 0 0 Sandeep Kumar 1 years 51 weeks
669 Preserve Source Partition in Kafka Streams from context 0 0 0 satya k 1 years 51 weeks
668 Expose REST endpoint to list converter plugins 0 0 0 Rupesh Kumar Patel 1 years 51 weeks
665 Kafka Connect Hash SMT 0 0 0 Brandon Brown 1 years 52 weeks
660 Pluggable ReplicaPlacer 0 0 0 Mickael Maison 2 years 1 weeks
658 [DISCARD] KIP-658 Deprecate all setters of Headers 0 0 0 Chia-Ping Tsai 2 years 1 weeks
657 Add Customized Kafka Streams Logo
1 Bruno Cadonna
0 0 Boyang Chen 2 years 2 weeks
656 MirrorMaker2 Exactly-once Semantics 0 0 0 Ning Zhang 2 years 3 weeks
655 Windowed Distinct Operation for Kafka Streams API 0 0 0 Ivan Ponomarev 2 years 3 weeks
650 Enhance Kafkaesque Raft semantics 0 0 0 Boyang Chen 2 years 4 weeks
649 Dynamic Client Configuration 0 0 0 Ryan Dielhenn 2 years 4 weeks
647 Add ability to handle late messages in streams-aggregation 0 0 0 Igor Piddubnyi 2 years 5 weeks
644 Support sources which can't give out changed data in kafka connect 0 0 0 Nikhil Kumar 2 years 6 weeks
642 Dynamic quorum reassignment 0 0 0 Jason Gustafson 2 years 7 weeks
641 An new java interface to replace 'kafka.common.MessageReader' 0 0 0 Chia-Ping Tsai 2 years 7 weeks
640 Add log compression analysis tool 0 0 0 Christopher Beard 2 years 9 weeks
639 Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics 0 0 0 mohamed chebbi 2 years 7 weeks
637 Include min.insync.replicas in MetadataResponse to make Producer smarter in partitioning events 0 0 0 Arvin Zheng 2 years 8 weeks
636 Make RPC error codes and messages tagged fields 0 0 0 Tom Bentley 2 years 8 weeks
631 The Quorum-based Kafka Controller
4 Boyang Chen
Colin McCabe
Ron Dagostino
Ismael Juma
0 0 Colin McCabe 2 years 9 weeks
628 ConsumerPerformance's multi-thread implementation 0 0 0 Jiamei.xie 2 years 10 weeks
625 Richer encodings for integral-typed protocol fields 0 0 0 Tom Bentley 2 years 10 weeks
624 Consolidate Offset Validation into Fetch Protocol 0 0 0 Boyang Chen 2 years 10 weeks
619 Add internal topic creation support 0 0 0 Cheng Tan 2 years 13 weeks
611 Improved Handling of Abandoned Connectors and Tasks 0 0 0 Chris Egerton 2 years 16 weeks
609 Use Pre-registration and Blocking Calls for Better Transaction Efficiency 0 0 0 Boyang Chen 2 years 16 weeks
603 Change `ConfigEntry` value to use optional fields 0 0 0 Wang Ge 2 years 17 weeks
598 Augment TopologyDescription with store and source / sink serde information 0 0 0 Guozhang Wang 2 years 18 weeks
596 Safely abort Producer transactions during application shutdown
2 Boyang Chen
John Roesler
0 0 Xiang Zhang 2 years 19 weeks
592 MirrorMaker 1.0 should replicate topics from earliest 0 0 0 Jeff Widman 2 years 20 weeks
587 Suppress detailed responses for handled exceptions in security-sensitive environments 0 0 0 Connor Penhale 2 years 21 weeks
583 add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker 0 0 0 Chia-Ping Tsai 2 years 23 weeks
582 Add a "continue" option for Kafka Connect error handling 0 0 0 Zihan Li 2 years 23 weeks
581 Value of optional null field which has default value 0 0 0 Cheng Pan 2 years 23 weeks
579 new exception on min.insync.replicas > replication.factor 0 0 0 Paolo Moriello 2 years 24 weeks
578 Add configuration to limit number of partitions
1 Harsha Ch
0 0 Gokul Ramanan Subramanian 2 years 24 weeks
576 Support dynamic update of more broker configs related to replication 0 0 0 Cheng Tan 2 years 24 weeks
575 build a Kafka-Exporter by Java 0 0 0 francis lee 2 years 25 weeks
568 Support RPC message type 'double'
4 Bill Bejeck
Navinder Brar
Konstantine Karantasis
John Roesler
0 0 Brian Byrne 2 years 31 weeks
567 Kafka Cluster Audit
1 Viktor Somogyi-Vass
0 0 Igor Martemyanov 2 years 31 weeks
566 Add rebalance callbacks to ConsumerInterceptor 0 0 0 Tommy Becker 2 years 31 weeks
563 Add 'tail -n' feature for ConsoleConsumer 0 0 0 huxihx 2 years 31 weeks
561 Regex Support for ConsumerGroupCommand 0 0 0 Alex Dunayevsky 2 years 35 weeks
560 Auto infer external topic partitions in stream reset tool 0 0 0 high.lee 2 years 32 weeks
550 Mechanism to Delete Stray Partitions on Broker 0 0 0 Dhruvil Shah 2 years 37 weeks
549 Surface Consumer's Metadata in KafkaAdminClient#describeConsumerGroups 0 0 0 David Jacot 2 years 39 weeks
548 Add Option to enforce rack-aware custom partition reassignment execution 0 0 0 Satish Bellapu 2 years 40 weeks
547 Extend ConsumerInterceptor to allow modification of Consumer Commits 0 0 0 Eric Azama 2 years 40 weeks
542 Partition Reassignment Throttling 0 0 0 Viktor Somogyi 2 years 44 weeks
540 Implement per key stream time tracking 0 0 0 Richard Yu 2 years 44 weeks
539 Implement mechanism to flush out records in low traffic suppression buffers 0 0 0 Richard Yu 2 years 45 weeks
536 Propagate broker start time to Admin API 0 0 0 Noa Resare 2 years 45 weeks
532 Broker Consumer Lag metrics in size and time 0 0 0 NIKHIL BHATIA 2 years 0 weeks
526 Reduce Producer Metadata Lookups for Large Number of Topics
2 Guozhang Wang
Jason Gustafson
0 0 Brian Byrne 2 years 49 weeks
514 Add a bounded flush() API to Kafka Producer 0 0 0 kun du 2 years 0 weeks
513 Distinguish between Key and Value serdes in scala wrapper library for kafka streams 0 0 0 Mykhailo Yeromenko 3 years 1 weeks
512 Adding headers to RecordMetaData 0 0 0 Renuka Metukuru 3 years 1 weeks
510 Metrics library upgrade 0 0 0 Mario Molina 3 years 1 weeks
509 Rebalance and restart Producers 0 0 0 Werner Dähn 3 years 1 weeks
508 Make Suppression State Queriable 0 0 0 Dongjin Lee 3 years 2 weeks
506 Allow setting SCRAM password via Admin interface 0 0 0 Tom Bentley 3 years 3 weeks
505 Add new public method to only update assignment metadata in consumer 0 0 0 Jungtaek Lim 3 years 3 weeks
503 Add metric for number of topics marked for deletion
1 David Arthur
0 0 David Arthur 3 years 3 weeks
502 Connect Task Method Signature to be More Specific for Developers 0 0 0 Cyrus Vafadari 3 years 3 weeks
501 Avoid out-of-sync or offline partitions when follower fetch requests are not processed in time 0 0 0 Satish Duggana 3 years 4 weeks
498 Add client-side configuration for maximum response size to protect against OOM 0 0 0 Alexandre Dupriez 3 years 4 weeks
495 Dynamically Adjust Log Levels in Connect
2 Cyrus Vafadari
Chris Egerton
0 0 Arjun Satish 3 years 5 weeks
494 Connect REST Endpoint to get Transformations (SMTs) 0 0 0 Cyrus Vafadari 3 years 5 weeks
491 Preferred Leader Deprioritized List (Temporary Blacklist) 0 0 0 George Li 3 years 6 weeks
490 New metric to count offsets expired without being consumed by a consumer group 0 0 0 Jose Morales Aragon 3 years 7 weeks
487 Client-side Automatic Topic Creation on Producer 0 0 0 Justine Olshan 3 years 7 weeks
483 Add Broker Version API in Admin Client 0 0 0 Boyang Chen 3 years 9 weeks
477 Add PATCH method for connector config in Connect REST API 0 0 0 Ivan Yurchenko 3 years 11 weeks
473 Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers 0 0 0 Ryan Pridgeon 3 years 14 weeks
469 Pre-registration support for static members 0 0 0 Boyang Chen 3 years 15 weeks
468 Avoid decompression of record when validate record at server in the scene of inPlaceAssignment . 0 0 0 Flowermin 3 years 15 weeks
463 Auto-configure non-default Serdes passed alongside the TopologyBuilder 0 0 0 Richard Yu 3 years 18 weeks
459 Improve KafkaStreams#close 0 0 0 Dongjin Lee 3 years 18 weeks
457 Add DISCONNECTED status to Kafka Streams 0 0 0 Richard Yu 3 years 19 weeks
452 Tool to view cluster status 0 0 0 Łukasz Antoniak 3 years 20 weeks
448 Add State Stores Unit Test Support to Kafka Streams Test Utils 0 0 0 Yishun Guan 3 years 21 weeks
439 Cleanup built-in Store interfaces 0 0 0 Matthias J. Sax 3 years 24 weeks
438 Expose task, connector IDs in Connect API 0 0 0 Ryanne Dolan 3 years 25 weeks
435 Internal Partition Reassignment Batching 0 0 0 Viktor Somogyi 3 years 27 weeks
433 Block old clients on brokers 0 0 0 Ying Zheng 3 years 27 weeks
426 Persist Broker Id to Zookeeper 0 0 0 Kan Li 3 years 29 weeks
424 Allow suppression of intermediate events based on wall clock time 0 0 0 Jonathan Gordon 3 years 31 weeks
423 Add JoinReason to Consumer Join Group Protocol 0 0 0 Boyang Chen 3 years 30 weeks
419 Safely notify Kafka Connect SourceTask is stopped 0 0 0 Andrew Schofield 3 years 32 weeks
410 Add metric for request handler thread pool utilization by request type 0 0 0 Mayuresh Gharat 3 years 36 weeks
409 Allow creating under-replicated topics and partitions
1 M. Manna
1 M. Manna
0 Mickael Maison 3 years 36 weeks
408 Add Asynchronous Processing To Kafka Streams 0 0 0 Richard Yu 3 years 36 weeks
406 GlobalStreamThread should honor custom reset policy 0 0 0 Richard Yu 3 years 36 weeks
403 Increase ProducerPerformance precision by using nanoTime 0 0 0 Kevin Lu 3 years 37 weeks
400 Improve exit status in case of errors in ConsoleProducer 0 0 0 Kamal Kang 3 years 41 weeks
399 Extend ProductionExceptionHandler to cover serialization exceptions
2 Guozhang Wang
Anna McDonald
0 0 Kamal Chandraprakash 3 years 38 weeks
398 Support reading trust store from classpath 0 0 0 Noa Resare 3 years 39 weeks
397 Add methods to override fetch offsets based on timestamp 0 0 0 Brandon Kirchner 3 years 39 weeks
395 Encypt-then-MAC Delegation token metadata 0 0 0 Attila Sasvári 3 years 39 weeks
391 Allow Producing with Offsets for Cluster Replication 0 0 0 Edoardo Comar 3 years 40 weeks
388 Add observer interface to record request and response 0 0 0 Lincong Li 3 years 42 weeks
387 Fair Message Consumption Across Partitions in KafkaConsumer 0 0 0 CHIENHSING WU 3 years 42 weeks
385 Avoid throwing away prefetched data 0 0 0 Zahari Dichev 3 years 44 weeks
384 Add config for incompatible changes to persistent metadata 0 0 0 Jason Gustafson 3 years 45 weeks
381 Connect: Tell about records that had their offsets flushed in callback 0 0 0 Per Steffensen 3 years 46 weeks
375 Kafka Clients - make Metadata#TOPIC_EXPIRY_MS configurable 0 0 0 Pavel Moukhataev 3 years 48 weeks
370 Remove Orphan Partitions 0 0 0 xiongqi wu 3 years 51 weeks
363 Allow performance tools to print final results to output file
1 =?UTF-8?Q?Attila_Sasv=C3=A1ri?=
0 0 Attila Sasvári 4 years 2 weeks
362 Support dynamic gap session window 0 0 0 Lei Chen 4 years 1 weeks
350 Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it 0 0 0 Ratish Ravindran 4 years 4 weeks
349 Priorities for Source Topics
1 Dongjin Lee
0
1 Colin McCabe
Nick Afshartous 4 years 4 weeks
348 Deprecate null from SourceTask#poll() 0 0 0 Chia-Ping Tsai 4 years 4 weeks
347 Enable batching in FindCoordinatorRequest 0 0 0 Yishun Guan 4 years 5 weeks
343 Add a Controller Heartbeat Mechanism 0 0 0 Colin McCabe 4 years 6 weeks
340 Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file
1 Dong Lin
0 0 Dong Lin 4 years 7 weeks
335 Consider configurations for KafkaStreams 0 0 0 Richard Yu 4 years 7 weeks
333 Add faster mode of rebalancing 0 0 0 Richard Yu 4 years 8 weeks
326 Schedulable KTable as Graph source 0 0 0 Flavio Stutz 4 years 9 weeks
325 Extend Consumer Group Command to Show Beginning Offsets 0 0 0 Vahid Hashemian 4 years 9 weeks
322 Return new error code for DeleteTopics API when topic deletion disabled.
1 Jason Gustafson
0 0 Manikumar Reddy O. 4 years 10 weeks
320 Allow fetchers to detect and handle log truncation
1 Jun Rao
0 0 Jason Gustafson 4 years 10 weeks
317 Add end-to-end data encryption functionality to Apache Kafka 0 0 0 Sönke Liebau 4 years 10 weeks
316 Command-line overrides for ConnectDistributed worker properties 0 0 0 Kevin Lafferty 4 years 11 weeks
315 Stream Join Sticky Assignor 0 0 0 Mike Freyberger 4 years 11 weeks
314 KTable to GlobalKTable Bi-directional Join 0 0 0 Adam Bellemare 4 years 12 weeks
304 Connect runtime mode improvements for container platforms 0 0 0 Saulius Valatka 4 years 15 weeks
301 Schema Inferencing for JsonConverter 0 0 0 Allen Tang 4 years 16 weeks
296 Connector level configurability for client configs 0 0 0 Allen Tang 4 years 16 weeks
293 Add new metrics for consumer/replication fetch requests 0 0 0 Adam Kotwasinski 4 years 17 weeks
287 Support partition and processor expansion for stateful processing jobs 0 0 0 Dong Lin 4 years 19 weeks
286 producer.send() should not block on metadata update 0 0 0 Dong Lin 4 years 20 weeks
273 Kafka to support using ETCD beside Zookeeper 0 0 0 Balint Molnar 4 years 22 weeks
271 Add NetworkClient redirector 0 0 0 Sergey Korytnikov 4 years 24 weeks
270 A Scala Wrapper Library for Kafka Streams
3 John Roesler
Damian Guy
Ismael Juma
0 0 Debasish Ghosh 4 years 24 weeks
264 Add a consumer metric to record raw fetch size 0 0 0 Vahid Hashemian 4 years 26 weeks
263 Allow broker to skip sanity check of inactive segments on broker startup 0 0 0 Dong Lin 4 years 26 weeks
260 add primary join operation for Stream-Stream join (WIP) 0 0 0 Boyang Chen 4 years 35 weeks
259 Improve Streams DSL Timestamp Propagation Semantics 0 0 0 Matthias J. Sax 4 years 27 weeks
256 Add RocksDB statistics via Streams metrics 0 0 0 jameschien 4 years 27 weeks
254 JsonConverter Exception Handeling 0 0 0 Prasanna Subburaj 4 years 28 weeks
253 Support in-order message delivery with partition expansion 0 0 0 Dong Lin 4 years 29 weeks
252 Extend ACLs to allow filtering based on ip ranges and subnets 0 0 0 Sönke Liebau 4 years 30 weeks
250 Add Support for Quorum-based Producer Acknowledgment 0 0 0 Litao Deng 4 years 31 weeks
249 Add Delegation Token Operations to KafkaAdminClient 0 0 0 Manikumar Reddy O. 4 years 32 weeks
242 Mask password in Kafka Connect Rest API response 0 0 0 Vincent Meng 4 years 36 weeks
241 KTable repartition with compacted Topics 0 0 0 Jan Filipiak 4 years 36 weeks
240 AdminClient.listReassignments AdminClient.describeReassignments 0 0 0 Tom Bentley 4 years 37 weeks
236 Interruptible Partition Reassignment 0 0 0 Tom Bentley 4 years 38 weeks
234 add support for getting topic defaults from AdminClient 0 0 0 dan norwood 4 years 38 weeks
232 Detect outdated metadata using leaderEpoch and partitionEpoch
1 Guozhang Wang
1 Dong Lin
0 Dong Lin 4 years 39 weeks
228 Negative record timestamp support 0 0
2 Guozhang Wang
Gwen Shapira
Konstantin Chukhlomin 4 years 39 weeks
209 Connection String Support 0 0 0 Clebert Suconic 4 years 45 weeks
201 Rationalising Policy interfaces
1 Stephane Maarek
0 0 Tom Bentley 4 years 50 weeks
199 Add Kafka Connect offset tool 0 0 0 Randall Hauch 4 years 50 weeks
193 Add SchemaBuilder.from(Schema) 0 0 0 Ewen Cheslack-Postava 4 years 52 weeks
185 Make exactly once in order delivery per partition the default producer setting 0 0 0 Apurva Mehta 5 years 3 weeks
181 DescribeGroups Protocol Enhancement 0 0 0 Vahid Hashemian 5 years 5 weeks
178 Size-based log directory selection strategy 0 0 0 huxihx 5 years 6 weeks
169 Lag-Aware Partition Assignment Strategy 0 0 0 Grant Neale 5 years 10 weeks
166 Add a tool to make amounts of replicas and leaders on brokers balanced 0 0 0 Ma Tianchi 5 years 13 weeks
159 Introducing Rich functions to Streams 0 0 0 Jeyhun Karimov 5 years 14 weeks
148 Add a connect timeout for client 0 0 0 pengwei 5 years 18 weeks
142 Add ListTopicsRequest to efficiently list all the topics in a cluster 0 0 0 Colin McCabe 5 years 19 weeks
139 Kafka TestKit library 0 0 0 Ismael Juma 5 years 20 weeks
135 Send of null key to a compacted topic should throw non-retriable error back to user 0 0 0 Mayuresh Gharat 5 years 23 weeks
125 ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback 0 0 0 Onur Karaman 5 years 27 weeks
95 Incremental Batch Processing for Kafka Streams 0 0 0 Matthias J. Sax 5 years 40 weeks
87 Add Compaction Tombstone Flag 0 0 0 Michael André Pearce 5 years 44 weeks
76 Enable getting password from executable rather than passing as plaintext in config files 0 0 0 Ashish Singh 6 years 1 weeks
72 Allow putting a bound on memory consumed by Incoming requests 0 0 0 Radai Rosenblatt 6 years 4 weeks
69 Kafka Schema Registry 0 0 0 Harsha 6 years 9 weeks
68 Add a consumed log retention before log retention 0 0 0 pengwei 6 years 9 weeks
64 Allow underlying distributed filesystem to take over replication depending on configuration 0 0 0 Arvind Kandhare 6 years 10 weeks
61 Add a log retention parameter for maximum disk space usage percentage 0 0 0 Ben Drees 6 years 16 weeks
60 Make Java client classloading more flexible 0 0 0 Rajini Sivaram 6 years 16 weeks
59 Proposal for a kafka broker command 0 0 0 Jayesh Thakrar 6 years 16 weeks
53 Add custom policies for reconnect attempts to NetworkdClient 0 0 0 Florian Hussonnois 6 years 21 weeks
52 Connector Control APIs 0 0 0 Jason Gustafson 6 years 22 weeks
49 Fair Partition Assignment Strategy 0 0 0 Andrew Olson 6 years 27 weeks
47 Add timestamp-based log deletion policy 0 0 0 Bill Warshaw 6 years 29 weeks
46 Self Healing Kafka 0 0 0 Aditya Auradkar 6 years 30 weeks
45 Standardize all client sequence interaction on j.u.Collection. 0 0 0 Pierre-Yves Ritschard 6 years 31 weeks
44 Allow Kafka to have a customized security protocol 0 0 0 XIAO, TAO 6 years 31 weeks
37 Add Namespaces to Kafka 0 0 0 Ashish Singh 6 years 48 weeks
34 Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case 0 0 0 Bhavesh Mistry 6 years 50 weeks
30 Allow for brokers to have plug-able consensus and meta data storage sub systems 0 0 0 Joe Stein 7 years 27 weeks
29 Add an IsrPropagateIntervalMs configuration to KafkaConfig 0 0 0 Jiangjie Qin 7 years 4 weeks
27 Conditional Publish 0 0 0 Ben Kirwin 7 years 7 weeks
23 Add JSON/CSV output and looping options to ConsumerGroupCommand 0 0 0 Ashish Singh 7 years 17 weeks
17 Add HighwaterMarkOffset to OffsetFetchResponse 0 0 0 Grant Henke 7 years 23 weeks
14 Tools Standardization 0 0 0 Jiangjie Qin 7 years 27 weeks
6 New reassignment partition logic for rebalancing 0 0 0 Joe Stein 7 years 32 weeks

Status Key

Status Mentioned within the last N days
0
28
84
365
106751