Versions Compared

Old Version 6

changes.mady.by.user Colin McCabe

Saved on

compared with

New Version 7

changes.mady.by.user Colin McCabe

Saved on

Key

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

...

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.

KIPJIRAComponentComment
KIP-465: Add Consolidated Connector Endpoint to Connect REST API


KIP-462: Use local thread id for KStreams


KIP-461: Improve Replica Fetcher behavior at handling partition failure


KIP-458: Connector Client Config Override Policy


KIP-454: Expansion of the ConnectClusterState interface


KIP-453: Add close() method to RocksDBConfigSetter


KIP-449: Add connector contexts to log messages in Connect workers 


KIP-445: In-memory Session Store


KIP-443: Return to default segment.ms and segment.index.bytes in Streams repartition topics


KIP-442: Return to default max poll interval in Streams


KIP-436: Add a metric indicating start time KAFKA-7992

KIP-430 - Return Authorized Operations in Describe ResponsesKAFKA-7922 

KIP-428: Add in-memory window storeKAFKA-4730

KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)KAFKA-7904

KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured BrokersKAFKA-7896

KIP-421: Support resolving externalized secrets in AbstractConfigKAFKA-7847 

KIP-417: Allow JmxTool to connect to a secured RMI portKAFKA-7455

KIP-415: Incremental Cooperative Rebalancing in Kafka ConnectKAFKA-5505

KIP-411: Make default Kafka Connect worker task client IDs distinctKAFKA-5061Connect
KIP-402: Improve fairness in SocketServer processorsKAFKA-7719, KAFKA-7730
partially implemented in 2.2
KIP-361: Add Consumer Configuration to Disable Auto Topic CreationKAFKA-7320Core
KIP-351: Add --under-min-isr option to describe topics commandKAFKA-7236Core
KIP-339: Create a new IncrementalAlterConfigs APIKAFKA-7466

KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and SerdeKAFKA-6161

KIP-328: Ability to suppress updates for KTables

KAFKA-6556, KAFKA-4587, KAFKA-6443, KAFKA-7222, KAFKA-7223, KAFKA-7224

Streamspartially implemented since 2.1
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues 

KAFKA-4217 - and KAFKA-7875

Streamspartially implemented since 2.2
KIP-307: Allow to define custom processor names with KStreams DSLKAFKA-6958Streamspartially implemented in 2.3?
KIP-258: Allow to Store Record Timestamps in RocksDBKAFKA-3522 and KAFKA-8382 Streamspartially implemented in 2.3?