Page History

...

Also feel free to refer to this release page for more details of the included tickets.

Planned KIP Content

See Kafka Improvement Proposals for the full list of KIPs.

KIP	JIRA	Component	Comment
KIP-465: Add Consolidated Connector Endpoint to Connect REST API	KAFKA-8309	Connect
KIP-462: Use local thread id for KStreams	KAFKA-8285	Streams
KIP-461: Improve Replica Fetcher behavior at handling partition failure	KAFKA-8346	Core
KIP-458: Connector Client Config Override Policy	KAFKA-8265	Connect
KIP-454: Expansion of the ConnectClusterState interface	KAFKA-8231	Connect
KIP-453: Add close() method to RocksDBConfigSetter	KAFKA-8324	Streams
KIP-449: Add connector contexts to log messages in Connect workers	KAFKA-3816	Connect
KIP-445: In-memory Session Store	KAFKA-8029	Streams
KIP-443: Return to default segment.ms and segment.index.bytes in Streams repartition topics	KAFKA-7190	Streams
KIP-442: Return to default max poll interval in Streams	KAFKA-6399	Streams
KIP-436: Add a metric indicating start time	K AFKA-7992	Core
KIP-430 - Return Authorized Operations in Describe Responses	KAFKA-7922	Core
KIP-428: Add in-memory window store	KAFKA-4730	Streams
KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)	KAFKA-7904	Core
KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers	KAFKA-7896	Core
KIP-421: Support resolving externalized secrets in AbstractConfig	KAFKA-7847	Core
KIP-417: Allow JmxTool to connect to a secured RMI port	KAFKA-7455	Core
KIP-415: Incremental Cooperative Rebalancing in Kafka Connect	KAFKA-5505	Connect
KIP-411: Make default Kafka Connect worker task client IDs distinct	KAFKA-5061	Connect
KIP-402: Improve fairness in SocketServer processors	KAFKA-7719, KAFKA-7730	Core	partially Partially implemented in 2.2.
K IP-361: Add Consumer Configuration to Disable Auto Topic Creation	KAFKA-7320	Core
KIP-351: Add --under-min-isr option to describe topics command	KAFKA-7236	Core
KIP-339: Create a new IncrementalAlterConfigs API	KAFKA-7466	Core	Voted on a while ago, but first implemented in 2.3.
KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde	KAFKA-6161	Streams
KIP-328: Ability to suppress updates for KTables	KAFKA-6556, KAFKA-4587, KAFKA-6443, KAFKA-7222, KAFKA-7223, KAFKA-7224	Streams	partially Partially implemented since 2.1.
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues	KAFKA-4217 - and KAFKA-7875	Streams	partially Partially implemented since 2.2.
KIP-307: Allow to define custom processor names with KStreams DSL	KAFKA-6958	Streams	partially Partially implemented in 2.3?
KIP-258: Allow to Store Record Timestamps in RocksDB	KAFKA-3522 and KAFKA-8382	Streams	partially Partially implemented in 2.3?

Space shortcuts

Child pages

Versions Compared

Old Version 7

New Version 8

Key

Planned KIP Content