| KIP | JIRA | Status | Component | Committer |
|---|
| KIP-66: Single Message Transforms for Kafka Connect | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-3209 |
|---|
|
| Committed (with some minor follow up outstanding) | Connect | Ewen Cheslack-Postava |
| KIP-77: Improve Kafka Streams Join Semantics | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4001 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-84: Support SASL SCRAM mechanisms | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-3751 |
|---|
|
| Committed | Common/Clients/Broker | Jun Rao |
| KIP-85: Dynamic JAAS configuration for Kafka clients | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4259 |
|---|
|
| Committed | Clients | Ismael Juma Juma |
| KIP-88: OffsetFetch Protocol Update | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-3853 |
|---|
|
| Committed | Clients/Broker | Ewen Cheslack-Postava |
| KIP-89: Allow sink connectors to decouple flush and offset commit | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4161 |
|---|
|
| Committed | Connect | Ewen Cheslack-Postava |
| KIP-90 - Remove zkClient dependency from Streams | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4060 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-92 - Add per partition lag metrics to KafkaConsumer | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4381 |
|---|
|
| Committed | Consumer | Ewen Cheslack-Postava |
| KIP-93: Improve invalid timestamp handling in Kafka Streams | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4393 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-94 Session Windows | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-3452 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-96 - Add per partition metrics for in-sync and assigned replica count | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4458 |
|---|
|
| Committed | Broker | Ismael Juma Juma |
| KIP-97: Improved Kafka Client RPC Compatibility Policy | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4462 |
|---|
|
| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4506 |
|---|
|
(Refactoring)| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4507 |
|---|
|
(Primary patch)| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4508 |
|---|
|
(System test 1)| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4457 |
|---|
|
(CLI tool)| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4548 |
|---|
|
(System test 2)| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4630 |
|---|
|
(Pre-KIP-74 compatibility)| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4635 |
|---|
|
(Initial patch follow ups)| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4664 |
|---|
|
(docs)
| Mostly Committed (a couple of follow-ups in progress) | Clients | Ismael Juma Juma |
| KIP-99: Add Global Tables to Kafka Streams | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4490 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-100 - Relax Type constraints in Kafka Streams API | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4481 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-102 - Add close with timeout for consumers | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4426 |
|---|
|
| Committed | Consumer | Jason Gustafson |
| KIP-103: Separation of Internal and External traffic | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4565 |
|---|
|
| Jira |
|---|
| server | ASF JIRA |
|---|
| columns | key,summary,type,created,updated,due,assignee,reporter,priority,status,resolution |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4636 |
|---|
|
| Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4637 |
|---|
|
| Main functionality committed. KAFKA-4636 & KAFKA-4637 pushed to subsequent release. | Broker | Jason Gustafson |
| KIP-104: Granular Sensors for Streams | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-3715 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-105: Addition of Recording Level for Sensors | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-3715 |
|---|
|
| Committed | Streams | guozhang Wang |
| KIP-108: Create Topic Policy | | Jira |
|---|
| server | ASF JIRA |
|---|
| serverId | 5aa69414-a9e9-3523-82ec-879b028fb15b |
|---|
| key | KAFKA-4591 |
|---|
|
| Committed | Broker | Jason Gustafson |