KIP | JIRA | Component | Committer |
---|
KIP-81: Bound Fetch memory usage in the consumer | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-4133 |
---|
|
| Consumer | Jason Gustafson |
KIP-86: Configurable SASL callback handlers | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-4292 |
---|
|
| Security | Rajini Sivaram |
KIP-91 Provide Intuitive User Timeouts in The Producer | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-5886 |
---|
|
| Producer | |
KIP-118: Drop Support for Java 7 | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-4423 |
---|
|
| All | |
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-5295 |
---|
|
| Connect | Ewen Cheslack-Postava |
KIP-174 - Deprecate and remove internal converter configs in WorkerConfig | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-5540 |
---|
|
| Connect | Ewen Cheslack-Postava |
KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-5692 |
---|
|
| AdminClient | Jun Rao |
KIP-186: Increase offsets retention default to 7 days | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-3806 |
---|
|
| Broker | Jason Gustafson |
KIP-206: Add support for UUID serialization and deserialization | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-4932 |
---|
|
| Clients | |
KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-2334 |
---|
|
| Broker | |
KIP-211: Revise Expiration Semantics of Consumer Group Offsets | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-4682 |
---|
|
| Consumer | Jason Gustafson |
KIP-219 - Improve quota communication | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6028 |
---|
|
| Broker,Clients | Dong Lin |
KIP-222 - Add Consumer Group operations to Admin API | Jira |
---|
showSummary | true |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6058 |
---|
|
| AdminClient | guozhang Wang |
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6184 |
---|
|
| Consumer | Jun Rao |
KIP-237: More Controller Health Metrics | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-3473 |
---|
|
| Broker | Jun Rao |
KIP-244: Add Record Header support to Kafka Streams Processor API | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6850 |
---|
|
| Streams | guozhang Wang |
KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6386 |
---|
|
| Streams | guozhang Wang |
KIP-249: Add Delegation Token Operations to KafkaAdminClient | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6447 |
---|
|
| AdminClient | Jun Rao |
KIP-251: Allow timestamp manipulation in Processor API | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6454 |
---|
|
| Streams | Matthias Sax |
KIP-257 - Configurable Quota Management | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6576 |
---|
|
| Broker | Rajini Sivaram |
KIP-261: Add Single Value Fetch in Window Stores | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6560 |
---|
|
| Streams | guozhang Wang |
KIP-265: Make Windowed Serde to public APIs | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-4831 |
---|
|
| Streams | guozhang Wang |
KIP-266: Add TimeoutException to KafkaConsumer#position() | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6608 |
---|
|
| Consumer | Jason Gustafson |
KIP-267: Add Processor Unit Test Support to Kafka Streams Test Utils | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6473 |
---|
|
| Streams | Matthias Sax |
KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6054 |
---|
|
| Streams | Matthias Sax |
KIP-270 - A Scala Wrapper Library for Kafka Streams | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6670 |
---|
|
| Streams | guozhang Wang |
KIP-272: Add API version tag to broker's RequestsPerSec metric | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6514 |
---|
|
| Broker | Jason Gustafson |
KIP-274: Kafka Streams Skipped Records Metrics | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6376 |
---|
|
| Streams | guozhang Wang |
KIP-276 Add StreamsConfig prefix for different consumers | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6657 |
---|
|
| Streams | guozhang Wang |
KIP-279: Fix log divergence between leader and follower after fast leader fail over | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6361 |
---|
|
| Broker | Jun Rao |
KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6743 |
---|
|
| Tools | Jason Gustafson |
KIP-284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6535 |
---|
|
| Streams | Matthias Sax |
KIP-285: Connect Rest Extension Plugin | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6776 |
---|
|
| Connect | Ewen Cheslack-Postava |
KIP-292: Add transformValues() method to KTable | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6849 |
---|
|
| Streams | guozhang Wang |
KIP-294 - Enable TLS hostname verification by default | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-3665 |
---|
|
| Security | Ismael Juma Juma |
KIP-295: Add Streams Configuration Allowing for Optional Topology Optimization | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6874 |
---|
|
| Streams | Matthias Sax |
KIP-297: Externalizing Secrets for Connect Configurations | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6886 |
---|
|
| Connect | Ewen Cheslack-Postava |
KIP-298: Error Handling in Connect | Jira |
---|
server | ASF JIRA |
---|
serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
---|
key | KAFKA-6738 |
---|
|
| Connect | Ewen Cheslack-Postava |