Versions Compared

Key

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

...

- KIP-213: Support non-key joining in KTable
- KIP-307: Allow to define custom processor names with KStreams DSL
- KIP-309: Add toUpperCase support to sasl.kerberos.principal.to.local rule
- KIP-369: Alternative Partitioner to Support "Always Round-Robin" Selection
- KIP-379: Multiple Consumer Group Management
- KIP-382: MirrorMaker 2.0
- KIP-392: Allow consumers to fetch from closest replica
- KIP-396: Add Reset/List Offsets Operations to AdminClient
- KIP-412: Extend Admin API to support dynamic application log levels
- KIP-429: Kafka Consumer Incremental Rebalance ProtocolProtocol (Partially implemented)
- KIP-434: Add Replica Fetcher and Log Cleaner Count Metrics
- KIP-440: Extend Connect Converter to support headers

- KIP-444: Augment metrics for Kafka Stream (Partially Implemented)
- KIP-455: Admin API for Replica ReassignmentReassignment (Partially implemented)
- KIP-460: Admin Leader Election RPC
- KIP-464: Defaults for AdminClient#createTopic

- KIP-467: Augment ProduceResponse error messaging for specific culprit records (Partially implemented)
- KIP-470: TopologyTestDriver test input and output usability improvements
- KIP-471: Expose RocksDB Metrics in Kafka Streams (Partially Implemented)
- KIP-474: To deprecate WindowStore#put(key, value)
- KIP-475: New Metrics to Measure Number of Tasks on a Connector
- KIP-479: Add StreamJoined config object to Join
- KIP-480: Sticky Partitioner
- KIP-481: SerDe Improvements for Connect Decimal type in JSON
- KIP-482: The Kafka Protocol should Support Optional Fields
- KIP-484: Expose metrics for group and transaction metadata loading duration
- KIP-488: Clean up Sum,Count,Total Metrics
- KIP-492: Add java security providers in Kafka Security config
- KIP-495: Dynamically Adjust Log Levels in Connect
- KIP-496: Administrative API to delete consumer offsets
- KIP-503: Add metric for number of topics marked for deletion
- KIP-504: Add new Java Authorizer Interface
- KIP-525: Return topic metadata and configs in CreateTopics response
- KIP-507: Securing Internal Connect REST Endpoints

- KIP-511: Collect and Expose Client's Name and Version in the Brokers (Partially implemented)
- KIP-521: Enable redirection of Connect's log4j messages to a file by default
- KIP-528: Deprecate PartitionGrouper configuration and interface

...

KIPJIRAComponent
KIP-528: Deprecate PartitionGrouper configuration and interface

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8927

Streams
KIP-525 - Return topic metadata and configs in CreateTopics response

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8907

Core
KIP-521: Enable redirection of Connect's log4j messages to a file by default

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-5609

Connect
KIP-517: Add consumer metrics to observe user poll behavior

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8874

Clients
KIP-511: Collect and Expose Client's Name and Version in the Brokers

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8855

Core  

(Partially implemented) 

Core

KIP-507: Securing Internal Connect REST Endpoints

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8804

Connect
KIP-504 - Add new Java Authorizer Interface

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8760

Core
KIP-503: Add metric for number of topics marked for deletion

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8753

Core
KIP-496: Administrative API to delete consumer offsets

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8730

Core
KIP-495: Dynamically Adjust Log Levels in Connect

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7772

Connect
KIP-492: Add java security providers in Kafka Security config

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8669

Core
KIP-488: Clean up Sum,Count,Total Metrics

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8696

Clients
KIP-484: Expose metrics for group and transaction metadata loading duration

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6263

Clients
KIP-482: The Kafka Protocol should Support Optional Tagged Fields

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8885

Core
KIP-481: SerDe Improvements for Connect Decimal type in JSON

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8595

Connect
KIP-480: Sticky Partitioner

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8601

Clients
KIP-479: Add Materialized to Join

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8558

Streams
KIP-476: Add Java AdminClient Interface

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8454

Clients
KIP-475: New Metrics to Measure Number of Tasks on a Connector

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8447

Connect
KIP-474: To deprecate WindowStore#put(key, value)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7245

Streams
KIP-471: Expose RocksDB Metrics in Kafka Streams

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6498

Streams

 (Partially implemented) 

KIP-470: TopologyTestDriver test input and output usability improvements

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8233

Streams
KIP-467: Augment ProduceResponse error messaging for specific culprit records

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8729

ClientsKIP-466: Add support for List<T> serialization and deserialization

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8326

StreamsClients     (Partially implemented) 
KIP-464: Defaults for AdminClient#createTopic

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8305

Clients
KIP-460: Admin Leader Election RPC

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8286

Clients/Core
KIP-455: Create an Administrative API for Replica Reassignment

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8345

Clients/

Core

Core 

(Partially implemented)

KIP-444: Augment metrics for Kafka Streams

Streams 

(Partially implemented)Streams

KIP-440: Extend Connect Converter to support headers

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7273

Connect
KIP-434: Add Replica Fetcher and Log Cleaner Count Metrics

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7981

Core
KIP-429: Kafka Consumer Incremental Rebalance Protocol

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8179

Clients

(Partially implemented)

KIP-412: Extend Admin API to support dynamic application log levels

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7800

Core/Clients
KIP-396: Add Reset/List Offsets Operations to AdminClient

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7689

Clients
KIP-392: Allow consumers to fetch from closest replica

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8443

Core
KIP-382: MirrorMaker 2.0

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7500

Core
KIP-379: Multiple Consumer Group Management

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7471

Clients
KIP-369: Alternative Partitioner to Support "Always Round-Robin" Selection

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-3333

Clients
KIP-352: Distinguish URPs caused by reassignment

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8834

Core
KIP-309: Add toUpperCase support to sasl.kerberos.principal.to.local rule

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6883

Core
KIP-307: Allow to define custom processor names with KStreams DSL

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6958

StreamsKIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint

Jira
key
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
KAFKA-8611

Streams
KIP-213 Support non-key joining in KTable

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-3705

Streams

...

KIPJIRAComponent
KIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8611

Streams
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting

Jira
serverASF JIRA
columnskey,summary,type,created,updated,due,assignee,reporter,priority,status,resolution
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-7523

Streams
KIP-446: Add changelog topic configuration to KTable suppress

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8147

Streams
KIP-466: Add support for List<T> serialization and deserialization

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8326

Streams
KIP-497: Add inter-broker API to alter ISR

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8836

Core
KIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-8611

Streams