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 | Mentioned within the last N days |
---|---|
0 | |
28 | |
84 | |
365 | |
106751 |