Versions Compared

Key

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

...

KIPJIRAComponent
KIP-671: Introduce Kafka Streams Specific Uncaught Exception Handler

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-9331
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-6943
,

Kafka Streams
KIP-662: Throw Exception when Source Topics of a Streams App are Deleted

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

Kafka Streams
KIP-654: Aborted transaction with non-flushed data should throw a non-fatal exception

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

Kafka Clients
KIP-651 - Support PEM format for SSL certificates and private key
Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyKAFKA-10338


Core
KIP-648: Renaming getter method for Interactive Queries

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

Kafka Streams
KIP-632: Add DirectoryConfigProvider

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


KIP-626: Rename StreamsConfig config variable name

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

Kafka Streams
KIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig

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

Kafka Clients
KIP-617: Allow Kafka Streams State Stores to be iterated backwards

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

Kafka Streams
KIP-616: Rename implicit Serdes instances in kafka-streams-scala

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

Kafka Streams
KIP-613: Add end-to-end latency metrics to Streams

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

Kafka Streams
KIP-612: Ability to Limit Connection Creation Rate on Brokers

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

Core
KIP-607: Add Metrics to Kafka Streams to Report Properties of RocksDB

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

Kafka Streams
KIP-601: Configurable socket connection timeout in NetworkClient

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

Core
KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations

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

Core
KIP-597: MirrorMaker2 internal topics Formatters

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


KIP-588: Allow producers to recover gracefully from transaction timeouts

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

Kafka Clients
KIP-584: Versioning scheme for features

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


KIP-572: Improve timeouts and retries in Kafka Streams

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

Kafka Streams
KIP-554: Add Broker-side SCRAM Config API

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

Core
KIP-545: support automated consumer offset sync across clusters in MM 2.0

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

Mirror Maker 2.0
KIP-497: Add inter-broker API to alter ISR

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

Core
KIP-478 - Strongly typed Processor API

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

Kafka Streams
KIP-450: Sliding Window Aggregations in the DSL

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

Kafka Streams
KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter

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

Kafka Tools
KIP-81: Bound Fetch memory usage in the consumer

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

Kafka Clients


Postponed to subsequent release

...

KIPJIRAComponent
KIP-653: Upgrade log4j to log4j2

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


KIP-623: Add "internal-topics" option to streams application reset tool

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

Kafka Streams
KIP-608 - Expose Kafka Metrics in Authorizer

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

Core
KIP-590: Redirect Zookeeper Mutation Protocols to The Controller

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

Core
KIP-589 Add API to update Replica state in Controller

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

Core
KIP-580: Exponential Backoff for Kafka Clients

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

Kafka Clients
KIP-508: Make Suppression State Queriable

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

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

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


KIP-418: A method-chaining way to branch KStream

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

Kafka Streams
KIP-373: Allow users to create delegation tokens for other users

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


KIP-359: Verify leader epoch in produce requests

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

Core
KIP-280: Enhanced log compaction

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

Core
KIP-216: IQ should throw different exceptions for different errors

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

Kafka Streams
KIP-81: Bound Fetch memory usage in the consumer

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

Kafka Clients