THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!

Page History

Versions Compared

Key

This line was added.
This line was removed.
Formatting was changed.

...

KIP	Comment
KIP-6 - New reassignment partition logic for rebalancing	Needs more detail
KIP-10 - Running Producer, Consumers and Brokers on Mesos
KIP-14 - Tools standardization
KIP-17 - Add HighwaterMarkOffset to OffsetFetchResponse
KIP-23 - Add JSON/CSV output and looping options to ConsumerGroupCommand
KIP-27 - Conditional Publish
KIP-30 - Allow for brokers to have plug-able consensus and meta data storage sub systems
KIP-37 - Add Namespaces to Kafka
KIP-39: Pinning controller to broker
KIP-44 - Allow Kafka to have a customized security protocol
KIP-46 - Self Healing
KIP-47 - Add timestamp-based log deletion policy
KIP-49 - Fair Partition Assignment Strategy
KIP-53 - Add custom policies for reconnect attempts to NetworkdClient
KIP-59: Proposal for a kafka broker command
KIP-64 -Allow underlying distributed filesystem to take over replication depending on configuration
KIP-68 Add a consumed log retention before log retention
KIP-69 - Kafka Schema Registry	Draft
KIP-76 Enable getting password from executable rather than passing as plaintext in config files
KIP-87 - Add Compaction Tombstone Flag	Possibly displaced by KIP-82
KIP-95: Incremental Batch Processing for Kafka Streams
KIP-159: Introducing Rich functions to Streams
KIP-260: add primary join operation for Stream-Stream join (WIP)	Draft
KIP-269: Substitution Within Configuration Values
KIP-311: Async processing with dynamic scheduling in Kafka Streams
KIP-314: KTable to GlobalKTable Bi-directional Join
KIP-326: Schedulable KTable as Graph source
KIP-349: Priorities for Source Topics	Functionality can be realized with existing API although at a lower level.
KIP-335: Consider configurations for KafkaStreams
K IP-362: Support Dynamic Session Window
KIP-378: Enable Dependency Injection for Kafka Streams handlers
KIP-408: Add asynchronous processing to Kafka Streams
KIP-422: Add support for client quota configuration in the Kafka Admin Client	KIP-546 added the necessary APIs instead
KIP-457: Add DISCONNECTED status to Kafka Streams
KIP-459: Improve KafkaStreams#close
KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder
KIP-611: Improved Handling of Abandoned Connectors and Tasks	[DISCARD] KIP-658 Deprecate all setters of Headers

Discarded KIPs

Please insert new rows in sorted order (ascending by KIP number).

KIP

Comment

KIP-5 - Broker Configuration Management

Superseded by KIP-21

KIP-7 - Security - IP Filtering

KIP-9 - SSL Support

Adopted via KAFKA-1690 but not via this KIP process

KIP-18 - JBOD Support

Superseded by KIP-112 and KIP-113

KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request

KIP-29 - Add an IsrPropagateIntervalMs configuration to KafkaConfig

No longer need after KAFKA-2722

KIP-34 Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case

Per feedback it is better do this parition() method and avoid Thread Coordination etc.

KIP-50 - Move Authorizer to o.a.k.common package

Superseded by KIP-504

KIP-80: Kafka Rest Server

KIP-83 - Allow multiple SASL authenticated Java clients in a single JVM process

After KIP-85, no interface changes, reduced to KAFKA-4180

KIP-111: Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker.

Covered by KIP-189

KIP-116: Add State Store Checkpoint Interval Configuration

Currently not needed as checkpointing can be done on commit interval.

KIP-127: Pluggable JAAS LoginModule configuration for SSL

Similar functionality can be implemented using a custom PrincipalBuilder.

KIP-132: Augment KStream.print to allow extra parameters in the printed string

Duplicated by KIP-160

KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods

Covered by KIP-182

KIP-165: Extend Interactive Queries for return latest update timestamp per key

Covered by KIP-258

KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicy

Superseded by KIP-201: Rationalising Policy interfaces

KIP 172: Add regular-expression topic support for sink connector

Superseded by KIP-215: Add topic regex support for Connect sinks

KIP-179: Change ReassignPartitionsCommand to use AdminClient

KIP-184: Rename LogCleaner and related classes to LogCompactor

A lot of configuration change will cause more trouble and doesn't seems to be worth it

KIP 230: Name Windowing Joins

Covered by KIP-372: Naming Repartition Topics for Joins and Grouping

KIP-232: Detect outdated metadata using per-partition leaderEpoch field

Merged into KIP-320: Allow fetchers to detect and handle log truncation

KIP-246: Connect producers and consumers should inherit worker configs

Withdrawn because proposal could not be made backward compatible with existing behavior

KIP-248 - Create New ConfigCommand That Uses The New AdminClient

Discarded by author as it's partly covered in KIP-339 and KIP-422

KIP-259: Improve Streams DSL Timestamp Propagation Semantics

Change did not require a KIP.

KIP-262: Metadata should include number of state stores for task

Rejected since metadata is no longer required.

KIP-263: Allow broker to skip sanity check of inactive segments on broker startup

Withdrawn because the solution we agreed on does not require interface change

KIP-275 - Indicate "isClosing" in the SinkTaskContext

KIP-286: producer.send() should not block on metadata update

Withdrawn because the benefit of not having to wait for metadata is probably not worth the complexity added in producer.

KIP-288: [DISCARDED] Consumer.poll() timeout semantic change and new waitForAssignment method

Discarded in deference to KIP-266

KIP-310: Add a Kafka Source Connector to Kafka Connect

Withdrawn in favor of KIP-382.

KIP-327: Add describe all topics API to AdminClient

Withdrawn in-favor of filter support in Metadata API and KIP-142

KIP-344: The auto-generated client id should be passed to MetricsReporter

Bug fix so KIP not needed

KIP-364: Remove implicit Materialized, Consumed and Produced

Subsumed by KIP-365

KIP-383: Pluggable interface for SSL Factory

Replaced by KIP-519

KIP-398: Support reading trust store from classpath

Not enough interest in favour. Can be implemented with mechanism in

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-8191

KIP-404: Add Kafka Connect configuration parameter for disabling WADL output on OPTIONS request

Discarded, reported as a bug by

Jira

server	ASF JIRA
serverId	5aa69414-a9e9-3523-82ec-879b028fb15b
key	KAFKA-7759

KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation

A "security sanity check tool" is a more generic and appropriate solution.

KIP-451: Make TopologyTestDriver output iterable

Discarded in favor of KIP-456

KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver

Discarded in favor of KIP-470

KIP-472: Add header to RecordContext/ProducerRecord

Discarded due to change being far more complex than necessary for a simple bug

KIP-485: Make topic optional when using through() operations in DSL

Moved to KIP-221

KIP-486: Support custom way to load KeyStore and TrustStore

Discarded in favor of KIP-519

KIP-522: Update BrokerApiVersionsCommand to use AdminClient

Discarded as this KIP is likely to be misused

KIP-593: Enable --if-exists and --if-not-exists for AdminClient in TopicCommand

Superseded by KIP-604

KIP-615: add ConstrainedCooperativeStickyAssignor

Discarded in favor of modifying existing assignor

KIP-638: Deprecate DescribeLogDirsResponse.[LogDirInfo, ReplicaInfo]

Duplication of KIP-621

KIP-672: Introduce Kafka Streams Specific Uncaught Exception Handler

Combined with KIP-671

[DISCARD] KIP-658 Deprecate all setters of Headers

KIP Discussion Recordings

...