Versions Compared

Key

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

...

KIPComment
KIP-86: Configurable SASL callback handlers 
KIP-87 - Add Compaction Tombstone FlagPossibly displaced by KIP-82KIP-91 Provide Intuitive User Timeouts in The Producer 
KIP-95: Incremental Batch Processing for Kafka Streams 
KIP-110: Add Codec for ZStandard Compression 

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

 
KIP-113: Support replicas movement between log directories 
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback 
KIP 130: Expose states of active tasks to KafkaStreams public API  May be semi-overlapped with KIP-120
KIP-131 - Add access to OffsetStorageReader from SourceConnector 
KIP-132: Augment KStream.print to allow extra parameters in the printed string 
KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user 
KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors 
KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster 
KIP-145 - Expose Record Headers in Kafka Connectbuilds on KIP-82 (would be ideal to make 0.11 release so it can go out as one, but not mandatory)

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

 
KIP-148: Add a connect timeout for clientDraft

KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner

 
KIP-150 - Kafka-Streams Cogroup 
KIP-152 - Improve diagnostics for SASL authentication failures 
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics 
KIP-159: Introducing Rich functions to Streams 
KIP-160: Augment KStream.print() to allow users pass in extra parameters in the printed string 
KIP-161: streams record processing exception handlers 
KIP-162: Enable topic deletion by default 

...

 

Discarded KIPs

KIPComment
KIP-5 - Broker Configuration Management(Superseded by KIP-21)
KIP-7 - Security - IP Filtering 
KIP-9 - SSL SupportAdopted via KAFKA-1690 but not via this KIP process
KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request 
KIP-29 - Add an IsrPropagateIntervalMs configuration to KafkaConfigNo 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-80: Kafka Rest Server 
KIP-83 - Allow multiple SASL authenticated Java clients in a single JVM processAfter KIP-85, no interface changes, reduced to KAFKA-4180
KIP-116: Add State Store Checkpoint Interval ConfigurationCurrently not needed as checkpointing can be done on commit interval.
KIP-127: Pluggable JAAS LoginModule configuration for SSLSimilar functionality can be implemented using a custom PrincipalBuilder.

...