Versions Compared

Old Version 496

changes.mady.by.user Damian Guy

Saved on

compared with

New Version 497

changes.mady.by.user Damian Guy

Saved on

Key

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

...

KIP round-up

Next KIP Number: 173174

Use this number as the identifier for your KIP and increment this value.

...

KIPComment
KIP-86: Configurable SASL callback handlers 
KIP-91 Provide Intuitive User Timeouts in The Producer 
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-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-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-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(), KStream.writeAsText() to allow users pass in extra parameters in the printed string 
KIP-162: Enable topic deletion by default 
KIP-163: Lower the Minimum Required ACL Permission of OffsetFetch 
KIP-164 - Add unavailablePartitionCount and per-partition Unavailable metrics 
KIP-165: Extend Interactive Queries for return latest update timestamp per key

 

KIP-166 - Add a tool to make amounts of replicas and leaders on brokers balanced 
KIP-167: Add interface for the state store restoration process 

KIP-168: Add TotalTopicCount metric per cluster

 
KIP-169 - Lag-Aware Partition Assignment Strategy 
KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicy 
KIP-171 - Extend Consumer Group Reset Offset for Stream Application 
KIP 172: Add regular-expression topic support for sink connector 
KIP-173: Add prefix to StreamsConfig to enable setting default internal topic configs 

Dormant/inactive KIPs

KIPComment
KIP-6 - New reassignment partition logic for rebalancingNeeds more detail
KIP-10 - Running Producer, Consumers and Brokers on Mesos 
KIP-14 - Tools standardization 
KIP-17 - Add HighwaterMarkOffset to OffsetFetchResponse 
KIP-18 - JBOD Support 
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 RegistryDraft
KIP-76 Enable getting password from executable rather than passing as plaintext in config files 
KIP-87 - Add Compaction Tombstone FlagPossibly displaced by KIP-82
KIP-95: Incremental Batch Processing for Kafka Streams 

...