Versions Compared

Key

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

...

To create your own KIP, click on "Create" on the header and choose "KIP-Template" other than "Blank page"

Create from template
templateName54329345
templateId54329345
titleKIP-NEXT: Insert Title Here
buttonLabelCreate KIP
. If you don't have permission, please send an email with your Wiki ID to dev@kafka.apache.org and request permission (http://kafka.apache.org/contact). Also add an entry to the table "KIPs under discussion"  (for Streams API KIPs, please also add it to Kafka Streams sub page).

...

Here is the process for making a KIP:

  1. Create a page which is a child of this oneClick
    Create from template
    templateName54329345
    templateId54329345
    titleKIP-NEXT: Insert Title Here
    buttonLabelCreate KIP
    . Take the next available KIP number and give your proposal a descriptive heading. e.g. "KIP 42: Allow Infinite Retention With Bounded Disk Usage".
  2. Fill in the sections as described above
  3. Start a [DISCUSS] thread on the Apache mailing list. Please ensure that the subject of the thread is of the format [DISCUSS] KIP-{your KIP number} {your KIP heading} The discussion should happen on the mailing list not on the wiki since the wiki comment system doesn't work well for larger discussions. In the process of the discussion you may update the proposal. You should let people know the changes you are making. When you feel you have a finalized proposal 
  4. Once the proposal is finalized call a [VOTE] to have the proposal adopted. These proposals are more serious than code changes and more serious even than release votes. The criteria for acceptance is lazy majority. The vote should remain open for 72 hours.
  5. Please update the Please update the KIP wiki page, and the index below, to reflect the current stage of the KIP after a vote. This acts as the permanent record indicating the result of the KIP (e.g., Accepted or Rejected). Also report the result of the KIP vote to the voting thread on the mailing list so the conclusion is clear.

KIP round-up

Next KIP Number: 246342

Use this number as the identifier for your KIP and increment this value.

Adopted KIPs

KIP

Release

KIP-
1 - Remove support of request.required.acks0.9.0.0KIP-2 - Refactor brokers to allow listening on multiple ports and IPs0.9.0.0KIP-3 - Mirror Maker Enhancement0.9.0.0KIP-4 - Command line and centralized administrative operations0.9.0.0, 0.10.0.0, 0.10.1.0KIP-4 - Metadata Protocol Changes0.10.0.0KIP-8 - Add a flush method to the producer API0.9.0.0KIP-11 - Kafka Authorizer design0.9.0.0KIP-12 - Kafka Sasl/Kerberos and SSL implementation0.9.0.0
331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde2.1.0(WIP)
KIP-330: Add retentionPeriod in SessionBytesStoreSupplier2.1.0
KIP-324: Add method to get metrics() in AdminClient2.1.0
KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides2.1.0(WIP)
KIP-306: Configuration for Delaying Response to Failed Authentication2.1.0 (WIP)
KIP-305: Add Connect primitive number converters2.0.0
KIP-303: Add Dynamic Routing in Streams Sink2.0.0 (WIP)
KIP-298: Error Handling in Connect2.0.0
KIP-297: Externalizing Secrets for Connect Configurations2
KIP-13 - Quota Design0.9
.0.0
KIP-
15 - Add a close method with a timeout in the producer
295 Add Streams Configuration Allowing for Optional Topology Optimization2
0.9
.0.0
KIP-
16 - Automated Replica Lag Tuning
294 - Enable TLS hostname verification by default2
0.9
.0.0 (WIP)
KIP-
19 - Add a request timeout to NetworkClient
292: Add transformValues() method to KTable2
0.9
.0.0
KIP-
20 Enable log preallocate to improve consume performance under windows and some old Linux file system
290: Support for Prefixed ACLs2
0.9
.0.0
KIP-
21 - Dynamic Configuration
285: Connect Rest Extension Plugin2.
0.9.
0.0
(WIP)
KIP-
22 - Expose a Partitioner interface in the new producer
284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE2
0.9
.0.0
KIP-
25 - System test improvements
283: Efficient Memory Usage for Down-Conversion2.0.
0.9.0.
0
KIP-
26 - Add Kafka Connect framework for data import/export
282: Add the listener name to the authentication context2
0.9
.0.0 (WIP)
KIP-
28 - Add a processor client
281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User2
0.10
.0.0
KIP-
31 - Move to relative offsets in compressed message sets
279: Fix log divergence between leader and follower after fast leader fail over2.
0.10.
0.0
KIP-
32
278 - Add
timestamps
version option to Kafka
message
's commands2.0.
10.0.
0
KIP-
33 - Add a time based log index
277 - Fine Grained ACL for CreateTopics API2.0.0 (WIP)
0.10.1.0
KIP-
35 - Retrieving protocol version
276 - Add StreamsConfig prefix for different consumers2
0.10
.0.0
KIP-
36 - Rack aware replica assignment
274: Kafka Streams Skipped Records Metrics2
0.10
.0.0
KIP-
38: ZooKeeper Authentication
272: Add API version tag to broker's RequestsPerSec metric2
0.9
.0.0
KIP
-40: ListGroups and DescribeGroup
-270 - A Scala Wrapper Library for Kafka Streams2.
0.9.
0.0
KIP-
41: Consumer Max Records
268: Simplify Kafka Streams Rebalance Metadata Upgrade2
0.10
.0.0
KIP-
42
267: Add
Producer and Consumer Interceptors
Processor Unit Test Support to Kafka Streams Test Utils2
0.10
.0.0
KIP-
43: Kafka SASL enhancements
265: Make Windowed Serde to public APIs2.
0.10.
0.0
KIP-
45 - Standardize all client sequence interaction on j.u.Collection.
261: Add Single Value Fetch in Window Stores2
0.10
.0.0
KIP
-48 Delegation token support for Kafka
-257 - Configurable Quota Management2
1
.0.0
(WIP)
KIP-
50 - Move Authorizer to o.a.k.common package
255: OAuth Authentication via SASL/OAUTHBEARER2.0
0.10.1
.0
KIP-
51 - List Connectors REST API
251: Allow timestamp manipulation in Processor API2
0.10
.0.0
KIP-
52: Connector Control APIs
249: Add Delegation Token Operations to KafkaAdminClient2
0.10
.0.0
KIP-
54: Sticky Partition Assignment Strategy
247: Add public test utils for Kafka Streams1.1.0
0.11.0.0
KIP-
55: Secure Quotas for Authenticated Users
245: Use Properties instead of StreamsConfig in KafkaStreams constructor2.0.
0.10.1.
0
KIP-
56: Allow cross origin HTTP requests on all HTTP methods
244: Add Record Header support to Kafka Streams Processor API2
0.10
.0.0
KIP-
57 - Interoperable LZ4 Framing
243: Make ProducerConfig and ConsumerConfig constructors public1.1
0.10.0
.0
KIP-
58 - Make Log Compaction Point Configurable
239 Add queryableStoreName() to GlobalKTable1
0.10
.1.0
KIP-
60 - Make Java client classloading more flexible
238: Expose Kafka cluster ID in Connect REST API1
0.10
.1.0
KIP-
62: Allow consumer to send heartbeats from a background thread
237: More Controller Health Metrics2.0
0.10.1
.0
KIP-
63: Unify store and downstream caching in streams
233: Simplify StreamsBuilder#addGlobalStore1
0.10
.1.0
KIP-
65: Expose timestamps to Connect
231: Improve the Required ACL of ListGroups API2
0.10
.1.0 (WIP)
KIP-
66: Single Message Transforms for Kafka Connect
229: DeleteGroups API1.1
0.10.2.0 / 0.11.0
.0
KIP-
67: Queryable state for Kafka Streams
227 - Introduce Incremental FetchRequests to Increase Partition Scalability1.
0.10.
1.0
KIP-
70: Revise Partition Assignment Semantics on New Consumer's Subscription Change
226 - Dynamic Broker Configuration1
0.10
.1.0
KIP-
71: Enable log compaction and deletion to co-exist
225 - Use tags for consumer “records.lag” metrics1
0.10
.1.0
KIP-
72: Allow putting a bound on memory consumed by Incoming request 
224: Add configuration parameter `retries` to Streams API1.
0
1.0
KIP
-73: Replication Quotas
-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer2.0.
0.10.1.
0
KIP-
74: Add Fetch Response Size Limit in Bytes
222 - Add Consumer Group operations to Admin API2.0.0
KIP-220: Add AdminClient into Kafka Streams' ClientSupplier1
0.10
.1.0
KIP-
75 - Add per-connector Converters
219 - Improve quota communication2.0
0.10.1
.0
KIP-
78: Cluster Id
218: Make KafkaFuture.Function java 8 lambda compatible1
0.10
.1.0
KIP-
79 - ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer
215: Add topic regex support for Connect sinks1
0.10
.1.0
KIP-
77: Improve Kafka Streams Join Semantics
214: Add zookeeper.max.in.flight.requests config to the broker1.1
0.10.2
.0
KIP-
81: Bound Fetch memory usage in the consumer
212: Enforce set of legal characters for connector names1.1.0
KIP-211: Revise Expiration Semantics of Consumer Group Offsets2.1.0 (WIP)
KIP-
82 - Add Record Headers
210 - Provide for custom error handling when Kafka Streams fails to produce1.1
0.11.0
.0
KIP-
84: Support SASL SCRAM mechanisms
208: Add SSL support to Kafka Connect REST interface1.1.
0.10.2.
0
KIP-
85: Dynamic JAAS configuration for Kafka clients0.10.2.0KIP-88: OffsetFetch Protocol Update0.10.2.0KIP-89: Allow sink connectors to decouple flush and offset commit0.10.2.0KIP-90 - Remove zkClient dependency from Streams0.10.2.0KIP-91 Provide Intuitive User Timeouts in The Producer
207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change2.0.0 (WIP)
KIP-206: Add support for UUID serialization and deserialization2.1.0 (WIP)
KIP-205: Add all() and range() API to ReadOnlyWindowStore1.1.0
KIP-204 : Adding records deletion operation to the new Admin Client API1.1.0
(WIP)
KIP-
92 - Add per partition lag metrics to KafkaConsumer
203: Add toLowerCase support to sasl.kerberos.principal.to.local rule 1.1
0.10.2
.0
KIP-
93: Improve invalid timestamp handling in Kafka Streams
202: Move merge() from StreamsBuilder to KStream1.0.0
KIP-198: Remove ZK dependency from Streams Reset Tool1.0.0
KIP-197 Connect REST API should include the connector type when describing a connector1.0
0.10.2.0KIP-94 Session Windows0.10.2.0KIP-96 - Add per partition metrics for in-sync and assigned replica count0.10.2
.0
KIP-
97
196:
Improved Kafka Client RPC Compatibility Policy
Add metrics to Kafka Connect framework1.0.
0.10.2.
0
KIP-
98 - Exactly Once Delivery and Transactional Messaging
195: AdminClient.createPartitions1
0.11
.0.0
KIP-
99: Add Global Tables to Kafka Streams
192 : Provide cleaner semantics when idempotence is enabled1.0.0
KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern1.0
0.10.2.0KIP-100 - Relax Type constraints in Kafka Streams API0.10.2
.0
KIP-
101 - Alter Replication Protocol to use Leader Epoch rather than High Watermark for Truncation
190: Handle client-ids consistently between clients and brokers1
0.11
.0.0
KIP-
102 - Add close with timeout for consumers
189: Improve principal builder interface and add support for SASL1.0
0.10.2
.0
KIP
-103: Separation of Internal and External traffic
-188 - Add new metrics to support health checks1.0.
0.10.2.
0
KIP-
104: Granular Sensors for Streams
187 - Add cumulative count metric for all Kafka rate metrics1.0
 0.10.2
.0
KIP-
105: Addition of Record Level for Sensors
186: Increase offsets retention default to 7 days2.0
0.10.2
.0
KIP-
106
183 - Change
Default unclean.leader.election.enabled from True to False
PreferredReplicaLeaderElectionCommand to use AdminClient2
0.11
.0.0
KIP-
107: Add purgeDataBefore() API in AdminClient
182: Reduce Streams DSL overloads and allow easier use of custom storage engines1.
0.11.
0.0
KIP-
108: Create Topic Policy
180: Add a broker metric specifying the number of consumer group rebalances in progress1.1
0.10.2
.0
KIP-
109
177:
Old Consumer Deprecation
Consumer perf tool should count rebalance time1
0.11
.0.0
KIP-
112: Handle disk failure for JBOD
176: Remove deprecated new-consumer option for tools2
1
.0.0
KIP-
113: Support replicas movement between log directories
175: Additional '--describe' views for ConsumerGroupCommand1.1.0
KIP
-114: KTable state stores and improved semantics
-174 - Deprecate and remove internal converter configs in WorkerConfig2
0.11
.0.0
KIP-
115: Enforce offsets.topic.replication.factor upon __consumer_offsets auto topic creation
173: Add prefix to StreamsConfig to enable setting default internal topic configs1
0.11
.0.0
KIP
-117: Add a public AdminClient API for Kafka admin operations
-171 - Extend Consumer Group Reset Offset for Stream Application1.1
0.11.0
.0
KIP-
118: Drop Support for Java 7 in Kafka 0.11
168: Add GlobalTopicCount and GlobalPartitionCount metric per cluster1
2
.0.0
(WIP)
KIP-
119
167:
Drop Support for Scala 2.10 in Kafka 0.11
Add interface for the state store restoration process1.
0.11.
0.0

KIP-

120: Cleanup Kafka Streams builder API

164 - Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics

1.0.0
KIP-
121: Add KStream peek method
163: Lower the Minimum Required ACL Permission of OffsetFetch1
0.11
.0.0
KIP-
122: Add Reset Consumer Group Offsets tooling
162: Enable topic deletion by default1.
0.11.
0.0
KIP-
123: Allow per stream/table timestamp extractor
161: streams deserialization exception handlers1
0.11
.0.0
KIP-
124 - Request rate quotas
160: Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string1.0.0
KIP-157 - Add consumer config options to streams reset tool1
0.11.0.0KIP-126 - Allow KafkaProducer to split and resend oversized batches.0.11
.0.0
KIP-
128: Add ByteArrayConverter for Kafka Connect
156 Add option "dry run" to Streams application reset tool0.11.0.0
KIP-
129: Streams Exactly-Once Semantics
155 - Add range scan for windowed state stores0.11.0.0
KIP
130: Expose states of active tasks to KafkaStreams public API
-154 Add Kafka Connect configuration properties for creating internal topics0.11
1
.0.0
KIP-
133: Describe and Alter Configs Admin APIs
153: Include only client traffic in BytesOutPerSec metric0.11.0.0
KIP
-134: Delay initial consumer group rebalance
-152 - Improve diagnostics for SASL authentication failures1
0.11
.0.0
KIP-
136: Add Listener name to SelectorMetrics tags
151 Expose Connector type in REST API0.11.0.0
KIP-
137: Enhance TopicCommand
150 -
-describe to show topics marked for deletion
Kafka-Streams Cogroup2
0.11
.0.
0
0 (WIP)
KIP-
138: Change punctuate semantics
149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner1.
0
1.0 (partially implemented)
KIP-
140: Add administrative RPCs for adding, deleting, and listing ACLs
146 - Classloading Isolation in Connect

0.11.0.0

KIP
-143: Controller Health Metrics
-145 - Expose Record Headers in Kafka Connect1.1
0.11.0
.0
KIP-144: Exponential backoff for broker reconnect attempts0.11.0.0
KIP-
146 - Classloading Isolation in Connect
143: Controller Health Metrics0.11.0.0
KIP-
149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner
140: Add administrative RPCs for adding, deleting, and listing ACLs0.11.0.0
KIP-138: Change punctuate semantics1.0.0
KIP-137: Enhance TopicCommand --describe to show topics marked for deletion
1.1.0 (WIP)KIP-150 - Kafka-Streams Cogroup1.1.0 (WIP)KIP-151 Expose Connector type in REST API
0.11.0.0
KIP-
152 - Improve diagnostics for SASL authentication failures
136: Add Listener name to SelectorMetrics tags0.11
1
.0.0
KIP-
153: Include only client traffic in BytesOutPerSec metric
134: Delay initial consumer group rebalance0.11.0.0
KIP-
154 Add Kafka Connect configuration properties for creating internal topics
133: Describe and Alter Configs Admin APIs0.11.0.0
KIP
155 - Add range scan for windowed state stores
-130: Expose states of active tasks to KafkaStreams public API1.
0.11.
0.0
KIP
156 Add option "dry run" to Streams application reset tool
-129: Streams Exactly-Once Semantics0.11.0.0
KIP
157
-
Add consumer config options to streams reset tool
128: Add ByteArrayConverter for Kafka Connect0.11
1
.0.0
KIP
-160: Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string
-126 - Allow KafkaProducer to split and resend oversized batches.0.11
1
.0.0
KIP
-161: streams deserialization exception handlers
-124 - Request rate quotas0.11
1
.0.0
KIP-
162: Enable topic deletion by default
123: Allow per stream/table timestamp extractor0.11
1
.0.0
KIP-
163: Lower the Minimum Required ACL Permission of OffsetFetch
122: Add Reset Consumer Group Offsets tooling0.11
1
.0.0
KIP-
164 - Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics
121: Add KStream peek method

0.11

1

.0.0

KIP-
167: Add interface for the state store restoration process
120: Cleanup Kafka Streams builder API1.0.0
KIP-
168: Add GlobalTopicCount and GlobalPartitionCount metric per cluster
119: Drop Support for Scala 2.10 in Kafka 0.110.11
1
.0.0
KIP-
171 - Extend Consumer Group Reset Offset for Stream Application
118: Drop Support for Java 72.0
1.1
.0
KIP-
173: Add prefix to StreamsConfig to enable setting default internal topic configs
117: Add a public AdminClient API for Kafka admin operations0.11
1
.0.0
KIP-
175: Additional '--describe' views for ConsumerGroupCommand
115: Enforce offsets.topic.replication.factor upon __consumer_offsets auto topic creation0.11.0
1.1
.0
KIP-
177: Consumer perf tool should count rebalance time
114: KTable state stores and improved semantics0.11
1
.0.0
KIP-
180: Add a broker metric specifying the number of consumer group rebalances in progress
113: Support replicas movement between log directories1.1.0
KIP-
182: Reduce Streams DSL overloads and allow easier use of custom storage engines
112: Handle disk failure for JBOD1.0.0
KIP-
183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient1.1.0 (WIP)KIP-187 - Add cumulative count metric for all Kafka rate metrics
109: Old Consumer Deprecation0.11.0.0
KIP-108: Create Topic Policy0.10.2.0
KIP-107: Add deleteRecordsBefore() API in AdminClient0.11
1
.0.0

KIP-

188 - Add new metrics to support health checks

106 - Change Default unclean.leader.election.enabled from True to False

0.11
1
.0.0
KIP-
189: Improve principal builder interface and add support for SASL
105: Addition of Record Level for Sensors0.10.2
1.0
.0
KIP-
190: Handle client-ids consistently between clients and brokers
104: Granular Sensors for Streams 0.10.2
1.0
.0
KIP-
191: KafkaConsumer.subscribe() overload that takes just Pattern
103: Separation of Internal and External traffic0.10.2
1.0
.0
KIP
-192 : Provide cleaner semantics when idempotence is enabled
-102 - Add close with timeout for consumers0.10.2
1.0.0KIP-195: AdminClient.createPartitions1.0
.0
KIP
-196: Add metrics to Kafka Connect framework
-101 - Alter Replication Protocol to use Leader Epoch rather than High Watermark for Truncation0.11
1
.0.0
KIP
-197 Connect REST API should include the connector type when describing a connector
-100 - Relax Type constraints in Kafka Streams API0.10.2
1.0
.0
KIP-
198: Remove ZK dependency from Streams Reset Tool
99: Add Global Tables to Kafka Streams0.10.2
1.0
.0
KIP-
202: Move merge() from StreamsBuilder to KStream
98 - Exactly Once Delivery and Transactional Messaging0.11
1
.0.0
KIP-
203: Add toLowerCase support to sasl.kerberos.principal.to.local rule
97: Improved Kafka Client RPC Compatibility Policy0.10.2.0
KIP-96 - Add per partition metrics for in-sync and assigned replica count0.10.2
 1.1
.0
KIP-
204 : Adding records deletion operation to the new Admin Client API
94 Session Windows0.10.2
1.1
.0
KIP-
205: Add all() and range() API to ReadOnlyWindowStore
93: Improve invalid timestamp handling in Kafka Streams0.10.2.0
KIP-92 - Add per partition lag metrics to KafkaConsumer0.10.2.0
KIP-91 Provide Intuitive User Timeouts in The Producer2.0
1.1.0KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change1.1
.0 (WIP)
KIP-
210 - Provide for custom error handling when Kafka Streams fails to produce
90 - Remove zkClient dependency from Streams0.10.2
1.1
.0
KIP-
214: Add zookeeper.max.in.flight.requests config to the broker
89: Allow sink connectors to decouple flush and offset commit0.10.2.0
KIP-88: OffsetFetch Protocol Update0.10.2.0
KIP-86: Configurable SASL callback handlers2.0.0
KIP-85: Dynamic JAAS configuration for Kafka clients0.10.2.0
KIP-84: Support SASL SCRAM mechanisms0.10.2.0
KIP-82 - Add Record Headers0.11.0.0
KIP-81: Bound Fetch memory usage in the consumer2.0
1.1.0 (WIP)KIP-215: Add topic regex support for Connect sinks1.1.0 (WIP)KIP-218: Make KafkaFuture.Function java 8 lambda compatible1.1.0 (WIP)KIP-220: Add AdminClient into Kafka Streams' ClientSupplier1.1.0KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer1.1.0KIP-224: Add configuration parameter `retries` to Streams API1.1.0KIP-225 - Use tags for consumer “records.lag” metrics1.1
.0 (WIP)
KIP
-238: Expose Kafka cluster ID in Connect REST API
-79 - ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer0.10
1
.1.0
(WIP)
KIP-
239 Add queryableStoreName() to GlobalKTable
78: Cluster Id0.10
1
.1.0
(WIP)

KIPs under discussion

KIPComment
KIP-
59: Proposal for a kafka broker commandSent emails to Dev discussion group. Work tracked under KAFKA-3663.KIP-86: Configurable SASL callback handlers KIP-110: Add Codec for ZStandard Compression KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback KIP-131 - Add access to OffsetStorageReader from SourceConnector KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster KIP-145 - Expose Record Headers in Kafka Connectbuilds on KIP-82 (would be ideal to make 0.11 release so it can go out as one, but not mandatory)KIP-148: Add a connect timeout for client KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics KIP-159: Introducing Rich functions to Streams KIP-165: Extend Interactive Queries for return latest update timestamp per key

 

KIP-166 - Add a tool to make amounts of replicas and leaders on brokers balanced KIP-169 - Lag-Aware Partition Assignment Strategy 

KIP-174 - Deprecate and remove internal converter configs in WorkerConfig

 KIP-176: Remove deprecated new-consumer option for tools KIP-178: Size-based log directory selection strategy

 

KIP-185: Make exactly once in order delivery the default producer setting

 KIP-186: Increase offsets retention default to 7 days KIP-193: Add SchemaBuilder.from(Schema) KIP-199: Add Kafka Connect offset tool KIP-201: Rationalising Policy interfaces KIP-206: Add support for UUID serialization and deserializationVoting in progressKIP-208: Add SSL support to Kafka Connect REST interface

 

KIP-209: Connection String Support KIP-211: Revise Expiration Semantics of Consumer Group Offsets KIP-212: Enforce set of legal characters for connector names KIP-213 Support non-key joining in KTable KIP-216: IQ should throw different exceptions for different errors KIP-217: Expose a timeout to allow an expired ZK session to be re-created 

KIP-219 - Improve quota communication

 KIP-221: Repartition Topic Hints in Streams KIP-222 - Add Consumer Group operations to Admin APIVoting in progressKIP-226 - Dynamic Broker Configuration KIP-227 - Introduce Incremental FetchRequests to Increase Partition Scalability KIP-228 Negative record timestamp support KIP-229: DeleteGroups API KIP-231: Improve the Required ACL of ListGroups APIVoting in progressKIP-232: Detect outdated metadata using per-partition leaderEpoch field KIP-233: Simplify StreamsBuilder#addGlobalStore KIP-234: add support for getting topic defaults from AdminClient KIP-235: Add DNS alias support for secured connection KIP-236: Interruptible Partition Reassignment KIP-237: More Controller Health Metrics KIP-240: AdminClient.listReassignments() AdminClient.describeReassignments() KIP-243: Make ProducerConfig and ConsumerConfig constructors public   KIP-244: Add Record Header support to Kafka Streams KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructorVoting in progress

Dormant/inactive KIPs

Discarded KIPs

KIPComment
KIP-5 - Broker Configuration Management(Superseded by KIP-21)
KIP-7 - Security - IP Filtering 
KIP-9 - SSL SupportAdopted via KAFKA-1690 but not via this KIP process
KIP-18 - JBOD SupportSuperseded by KIP-112 and KIP-113 
KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request 
KIP-29 - Add an IsrPropagateIntervalMs configuration to KafkaConfigNo longer need after KAFKA-2722

KIP-34 Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case

Per feedback it is better do this parition() method and avoid Thread Coordination etc.
KIP-80: Kafka Rest Server 
KIP-83 - Allow multiple SASL authenticated Java clients in a single JVM processAfter KIP-85, no interface changes, reduced to KAFKA-4180
KIP-116: Add State Store Checkpoint Interval ConfigurationCurrently not needed as checkpointing can be done on commit interval.
KIP-127: Pluggable JAAS LoginModule configuration for SSLSimilar functionality can be implemented using a custom PrincipalBuilder.
KIP-132: Augment KStream.print to allow extra parameters in the printed string

Duplicated by KIP-160

KIP-184: Rename LogCleaner and related classes to LogCompactorA lot of configuraiton change will cause more trouble and doesn't seems to be worth it
KIP-111: Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker.(covered by KIP-189)
KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods(covered by KIP-182)
KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicysuperseded by KIP-201: Rationalising Policy interfaces
KIP 172: Add regular-expression topic support for sink connectorsuperseded by KIP-215: Add topic regex support for Connect sinks
KIP-179: Change ReassignPartitionsCommand to use AdminClient 

KIP Discussion Recordings

77: Improve Kafka Streams Join Semantics0.10.2.0
KIP-75 - Add per-connector Converters0.10.1.0
KIP-74: Add Fetch Response Size Limit in Bytes0.10.1.0
KIP-73: Replication Quotas0.10.1.0
KIP-72: Allow putting a bound on memory consumed by Incoming request 1.0.0
KIP-71: Enable log compaction and deletion to co-exist0.10.1.0
KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change0.10.1.0
KIP-67: Queryable state for Kafka Streams0.10.1.0
KIP-66: Single Message Transforms for Kafka Connect0.10.2.0 / 0.11.0.0
KIP-65: Expose timestamps to Connect0.10.1.0
KIP-63: Unify store and downstream caching in streams0.10.1.0
KIP-62: Allow consumer to send heartbeats from a background thread0.10.1.0
KIP-60 - Make Java client classloading more flexible0.10.1.0
KIP-58 - Make Log Compaction Point Configurable0.10.1.0
KIP-57 - Interoperable LZ4 Framing0.10.0.0
KIP-56: Allow cross origin HTTP requests on all HTTP methods0.10.0.0
KIP-55: Secure Quotas for Authenticated Users0.10.1.0
KIP-54: Sticky Partition Assignment Strategy0.11.0.0
KIP-52: Connector Control APIs0.10.0.0
KIP-51 - List Connectors REST API0.10.0.0
KIP-50 - Move Authorizer to o.a.k.common package0.10.1.0
KIP-48 Delegation token support for Kafka1.1.0
KIP-45 - Standardize all client sequence interaction on j.u.Collection.0.10.0.0
KIP-43: Kafka SASL enhancements0.10.0.0
KIP-42: Add Producer and Consumer Interceptors0.10.0.0
KIP-41: Consumer Max Records0.10.0.0
KIP-40: ListGroups and DescribeGroup0.9.0.0
KIP-38: ZooKeeper Authentication0.9.0.0
KIP-36 - Rack aware replica assignment0.10.0.0
KIP-35 - Retrieving protocol version0.10.0.0
KIP-33 - Add a time based log index0.10.1.0
KIP-32 - Add timestamps to Kafka message0.10.0.0
KIP-31 - Move to relative offsets in compressed message sets0.10.0.0
KIP-28 - Add a processor client0.10.0.0
KIP-26 - Add Kafka Connect framework for data import/export0.9.0.0
KIP-25 - System test improvements0.9.0.0
KIP-22 - Expose a Partitioner interface in the new producer0.9.0.0
KIP-21 - Dynamic Configuration0.9.0.0 (WIP)
KIP-20 Enable log preallocate to improve consume performance under windows and some old Linux file system0.9.0.0
KIP-19 - Add a request timeout to NetworkClient0.9.0.0
KIP-16 - Automated Replica Lag Tuning0.9.0.0
KIP-15 - Add a close method with a timeout in the producer0.9.0.0
KIP-13 - Quota Design0.9.0.0
KIP-12 - Kafka Sasl/Kerberos and SSL implementation0.9.0.0
KIP-11 - Kafka Authorizer design0.9.0.0
KIP-8 - Add a flush method to the producer API0.9.0.0
KIP-4 - Metadata Protocol Changes0.10.0.0
KIP-4 - Command line and centralized administrative operations0.9.0.0, 0.10.0.0, 0.10.1.0
KIP-3 - Mirror Maker Enhancement0.9.0.0
KIP-2 - Refactor brokers to allow listening on multiple ports and IPs0.9.0.0
KIP-1 - Remove support of request.required.acks0.9.0.0


KIPs under discussion

KIPComment
KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file
KIP-339: Create a new ModifyConfigs API
KIP-59: Proposal for a kafka broker commandSent emails to Dev discussion group. Work tracked under KAFKA-3663.
KIP-110: Add Codec for ZStandard Compression 
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback 
KIP-131 - Add access to OffsetStorageReader from SourceConnector 
KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user 
KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors 
KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster 
KIP-148: Add a connect timeout for client 
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics 
KIP-159: Introducing Rich functions to Streams 
KIP-165: Extend Interactive Queries for return latest update timestamp per key

 

KIP-166 - Add a tool to make amounts of replicas and leaders on brokers balanced 
KIP-169 - Lag-Aware Partition Assignment Strategy 
KIP-178: Size-based log directory selection strategy

 

KIP-185: Make exactly once in order delivery the default producer setting

 
KIP-193: Add SchemaBuilder.from(Schema) 
KIP-199: Add Kafka Connect offset tool 
KIP-201: Rationalising Policy interfaces 
KIP-209: Connection String Support 
KIP-213 Support non-key joining in KTable 
KIP-216: IQ should throw different exceptions for different errors 
KIP-217: Expose a timeout to allow an expired ZK session to be re-created 
KIP-221: Repartition Topic Hints in Streams 
KIP-228 Negative record timestamp supportVoting in progress
KIP 230: Name Windowing JoinsDiscussion
KIP-232: Detect outdated metadata using per-partition leaderEpoch fieldVoting in progress
KIP-234: add support for getting topic defaults from AdminClient 
KIP-235: Add DNS alias support for secured connectionAccepted
KIP-236: Interruptible Partition Reassignment 
KIP-240: AdminClient.listReassignments() AdminClient.describeReassignments() 
KIP-242: Mask password in Kafka Connect Rest API response 
KIP-248 - Create New ConfigCommand That Uses The New AdminClientVoting in progress (pending on more binding votes)
KIP-250 Add Support for Quorum-based Producer Acknowledgment 
KIP-252 - Extend ACLs to allow filtering based on ip ranges and subnets 
KIP-253: Support in-order message delivery with partition expansion 
KIP-254: JsonConverter Exception Handeling 
KIP-258: Allow to Store Record Timestamps in RocksDBdepends on KIP-268
KIP-259: Improve Streams DSL Timestamp Propagation Semantics 
KIP-260: add primary join operation for Stream-Stream join (WIP)Draft
KIP-262: Metadata should include number of state stores for taskdepends on KIP-268
KIP-264: Add a consumer metric to record raw fetch sizeVoting in progress
KIP-266: Fix consumer indefinite blocking behaviorAccepted
KIP-269: Substitution Within Configuration Valuesrequirement for KIP-255
KIP-271: Add NetworkClient redirectorDiscussion
KIP-273: Kafka to support using ETCD beside ZookeeperDiscussion
KIP-275 - Indicate "isClosing" in the SinkTaskContextVoting in progress
KIP-280: Enhanced log compactionVoting in progress
KIP-289: Improve the default group id behavior in KafkaConsumerDiscussion

KIP-291: Have separate queues for control requests and data requests

Voting in progress
KIP-293 Add new metrics for consumer/replication fetch requestsVoting in progress
KIP-296: Add connector level configurability for producer/consumer client configs Discussion
KIP-300: Add Windowed KTable API in StreamsBuilderDiscussion
KIP-301: Schema Inferencing for JsonConverterDiscussion
KIP-302 - Enable Kafka clients to use all DNS resolved IP addressesDiscussion
KIP-304: Connect runtime mode improvements for container platformsDiscussion
KIP-312 Add Overloaded StreamsBuilder Build Method to Accept java.util.PropertiesAccepted
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues Accepted
KIP-314: KTable to GlobalKTable Bi-directional JoinDiscussion
KIP-315: Stream Join Sticky AssignorDiscussion
KIP-316: Command-line overrides for ConnectDistributed worker propertiesDiscussion
KIP-317: Add transparent data encryption functionalityDiscussion
KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplierDiscussion
KIP-320: Allow fetchers to detect and handle log truncationDiscussion
KIP-321: Add method to get TopicNameExtractor in TopologyDescriptionDiscussion
KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.Discussion
KIP-325: Extend Consumer Group Command to Show Beginning Offsets and Partition SizeDiscussion
KIP-326: Schedulable KTable as Graph sourceDiscussion
KIP-328: Ability to suppress updates for KTablesDiscussion
KIP-333: Add faster mode of rebalancingDiscussion
KIP-335: Consider configurations for KafkaStreams

Discussion

KIP-336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/DeserializerDiscussion
KIP-338 Support to exclude the internal topics in kafka-topics.sh commandDiscussion
KIP-341: Update Sticky Assignor's User Data ProtocolDiscussion


Dormant/inactive KIPs

Discarded KIPs

KIPComment
KIP-5 - Broker Configuration Management(Superseded by KIP-21)
KIP-7 - Security - IP Filtering 
KIP-9 - SSL SupportAdopted via KAFKA-1690 but not via this KIP process
KIP-18 - JBOD SupportSuperseded by KIP-112 and KIP-113 
KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request 
KIP-29 - Add an IsrPropagateIntervalMs configuration to KafkaConfigNo longer need after KAFKA-2722

KIP-34 Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case

Per feedback it is better do this parition() method and avoid Thread Coordination etc.
KIP-80: Kafka Rest Server 
KIP-83 - Allow multiple SASL authenticated Java clients in a single JVM processAfter KIP-85, no interface changes, reduced to KAFKA-4180
KIP-116: Add State Store Checkpoint Interval ConfigurationCurrently not needed as checkpointing can be done on commit interval.
KIP-127: Pluggable JAAS LoginModule configuration for SSLSimilar functionality can be implemented using a custom PrincipalBuilder.
KIP-132: Augment KStream.print to allow extra parameters in the printed string

Duplicated by KIP-160

KIP-184: Rename LogCleaner and related classes to LogCompactorA lot of configuraiton change will cause more trouble and doesn't seems to be worth it
KIP-111: Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker.(covered by KIP-189)
KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods(covered by KIP-182)
KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicysuperseded by KIP-201: Rationalising Policy interfaces
KIP 172: Add regular-expression topic support for sink connectorsuperseded by KIP-215: Add topic regex support for Connect sinks
KIP-179: Change ReassignPartitionsCommand to use AdminClient 
KIP-246: Connect producers and consumers should inherit worker configsWithdrawn because proposal could not be made backward compatible with existing behavior
KIP-263: Allow broker to skip sanity check of inactive segments on broker startupWithdrawn because the solution we agreed on does not require interface change
KIP-286: producer.send() should not block on metadata updateWithdrawn because the benefit of not having to wait for metadata is probably not worth the complexity added in producer.
KIP-288: [DISCARDED] Consumer.poll() timeout semantic change and new waitForAssignment methoddiscarded in deference to KIP-266

KIP Discussion Recordings

Date (link to recording)Summary
2018-04-09
  • KIP-253 - partition expansion: We discussed a few things. (1) Is it useful to backfill a compacted topic? The main use case is to rebuild the application states. If the new partition has the existing data, rebuilding the state can be done easily by reading from a single partition. Otherwise, an application has to read both the child and the parent partition to rebuild the state. This is possible, but can be complicated. Jan will do an exercise to see how complicated this is. (2) What's the best way to add the backfilling support if we want to do it? We can do this on the server side or on the client side. The former potentially makes the coordination easier. The latter potentially reduces the memory footprint on the server for reshuffling. We need to think through how to support EOS message format and how to throttle the process to avoid overwhelming the cluster. (3) Linear hashing vs doubling partitions. It seems that Linear hashing is more general. (4) Partition splitting in Kinesis. This is done differently since it doesn't allow customized partitioning. It doesn't support compacted topic either. (5) Sticky partition assignment. It could be useful to support a partition assignment strategy where the child partition is assigned together with the parent partition to a consumer instance so that the local state doesn't have to be moved immediately. (6) Consumer callback on partition splitting. This could still be useful if the states are maintained globally.
Date (link to recording)Summary
2017-01-07
  • KIP-112 - Handle disk failure for JBOD: We discussed whether we need to support JBOD directly in Kafka or just rely on the 1 disk per broker model. The general consensus is that direct JBOD support in Kafka is needed. There is some concern on the complexity added to Kafka. So, we have to be careful with the implementation details. We discussed how directory failure should be detected, where the failure state is kept, and whether the state should be reset on broker restart. There is a bit confusing on what's written in the wiki. Dong is going to clarify the proposal based on the feedback and we will follow up on the details in the mailing list.
2016-10-19
  • KIP-82 - add record header: We agreed that there are use cases for third-party vendors building tools around Kafka. We haven't reached the conclusion whether the added complexity justifies the use cases. We will follow up on the mailing list with use cases, container format people have been using, and details on the proposal.
2016-09-13
  • KIP-54 (Sticky Partition Assignment): aims to minimise partition movement so that resource reinitialisation (e.g. caches) is minimised. It is partially sticky and partially fair. Some concerns around the fact that user code for partitionsRevoked and partitionsAssigned would have to be changed to work correctly with this assignment strategy. Good: more complex usage of an assigner that takes advantage of the user data field. Vahid will start the vote.

  • KIP-72 (Allow Sizing Incoming Request Queue in Bytes): large requests can kill the broker, no control over how much memory is allocated. Client quotas don't help as damage may already have been done by the time they kick in. There was a discussion on whether it was worth it to avoid the immediate return from select when there was no memory available in the pool. Radai will update the KIP to describe this aspect in more detail as well as the config validation that is performed.

  • KIP-79 (ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer): we discussed the option of passing multiple timestamps for the same partition in the same request. Becket thinks it's a rare use case and not worth supporting. Gwen said that it would be nice to have, but not essential. We talked about validation of duplicate topics. Becket will check the approach taken by the create topics request and evaluate if it can be adopted here too. PR will be available today and Jason will evaluate if it's feasible to include it in the next release once it's available.

2016-08-30
  • KIP48 (delegation tokens): Harsha will update the wiki with more details on how to use delegation tokens and how to configure it.
  • KIP-78 (cluster id): There was discussion on adding human readable tags later. No major concerns.
2016-08-23
  • time-based release: No one seems to have objections. Ismael will follow up with a release wiki.
  • KIP-4: We discussed having separate ACL requests of add and delete. No one seems to object to it. We discussed the admin client. Grant will send a PR. We discussed how KStream can use the ACL api.  It seems that we will need some kind of regex or namespace support in ACL to make the authorization convenient in KStream.
  • KIP-50: There is some discussion for further changes in the PR. Ashish will reply to the KIP email thread with the recommended changes. Ashish/Grant plan to look into whether it's possible to make the authorizer api change backward compatible. However, it seems that people are in general ok with a non-compatible api change.
  • KIP-74: No objections on the current proposal.
  • Java 7 support timeline: The consensus is to defer dropping the Java 7 support until the next major release (which will be next year). Ismael will follow up on the email thread.
  • KIP-48 delegation token : Ashish will ping Harsh to see if this is still active.
  • Some of the KIPs have been idle. Grant will send a proposal on tagging them properly (e.g., blocked, inactive, no resource, etc).
2016-05-24
  • KIP-58 - Make Log Compaction Point Configurable: We want to start with just a time-based configuration since there is no good usage for byte-based or message-based configuration. Eric will change the KIP and start the vote.
  • KIP-4 - Admin api: Grant will pick up the work. Initially, he plans to route the write requests from the admin clients to the controller directly to avoid having the broker forward the requests to the controller.
  • KIP-48 - Delegation tokens: Two of the remaining issues are (1) how to store the delegation tokens and (2) how token expiration works. Since Parth wasn't able to attend the meeting. We will follow up in the mailing list.
2016-04-05
  • KIP-4: There is a slight debate on the metadata request schema, as well as the internal ZK based implementation, which we will wait for Jun to comment on the mailing list thread.
  • KIP-52: We decided to start a voting process for this.
  • KIP-35: Decided on renaming ApiVersionQuery api to ApiVersion. Consensus on using the api in java client to only check for availability of current versions. ApiVersion api's versions will not be deprecated. Update KIP-35 wiki will be updated with latest info and vote thread will be initiated.
2016-03-15
  • KIP-33 - Add a time based log index to Kafka: We decided NOT to include this in 0.10.0 since the changes may have performance risks.
  • KIP-45 - Standardize all client sequence interaction on j.u.Collection: There is no consensus in the discussion. We will just put it to vote.
  • KIP-35 - Retrieving protocol version: This gets the longest discussion. There is still no consensus. Magnus thinks the current proposal of maintaining a global protocol version won't work and will try to submit a new proposal.
  • KIP-43 - Kafka SASL enhancements: Rajini will modify the KIP to only support native SASL mechanisms and leave the changes to Login and CallbackHandler to KIP-44 instead.
2016-02-23
  • KIP-33 and KIP-47: No issues. Will start the voting thread.
  • KIP-43: We discussed whether there is a need to support multiple SASL mechanisms at the same time and what's the best way to implement this. Will discuss this in more details in the email thread.
  • KIP-4: Grant gave a comprehensive summary of the current state. We have gaps on how to make the admin request block on the broker, how to integrate admin requests with ACL (especially with respect to client config changes for throttling and ACL changes), how to do the alter topic request properly. Grant will update the KIP with an interim plan and a long term plan.
  • KIP-43: We briefly discussed on to support multiple sasl mechanisms on the broker. Harsha will follow up with more details on the email thread.
  • Everyone seems to be in favor of making the next major release 0.10.0, instead of 0.9.1.
2016-01-26
  • KIP-42: We agreed to leave the broker side interceptor for another KIP. On the client side, people favor the 2nd option in Anna's proposal. Anna will update the wiki accordingly.
  • KIP-43: We discussed whether there is a need to support multiple SASL mechanisms at the same time and what's the best way to implement this. Will discuss this in more details in the email thread.
  • Jiangjie brought up an issue related to KIP-32 (adding timestamp field in the message). The issue is that currently there is no convenient way for the consumer to tell whether the timestamp in a message is the create time or the server time. He and Guozhang propose to use a bit in the message attribute to do that. Jiangjie will describe the proposal in the email thread.
2016-01-12
  • KIP-41: Discussed whether the issue of long processing time between poll calls is a common issue and whether we should revisit the poll api. Also discussed whether the number of records returned in poll calls can be made more dynamic. In the end, we feel that just adding a config that controls the number records returned in poll() is the simplest approach at this moment.
  • KIP-36: Need to look into how to change the broker JSON representation in ZK w/o breaking rolling upgrades. Otherwise, ready for voting.
2015-10-20
  • KIP-38: No concerns with this KIP. Flavio will initiate the voting on this.
  • KIP-37: There are questions on how ACL, configurations, etc will work, and whether we should support "move" or not. We will discuss the details more in the mailing list.
  • KIP-32/KIP-33: Jiangjie raised some concerns on the approach that Jay proposed. Guozhang and Jay will follow up on the mailing list.
2015-10-13
  • 0.9.0 release: We discussed if KAFKA-2397 should be a blocker in 0.9.0. Jason and Guozhang will follow up on the jira.
  • KIP-32 and KIP-33: We discussed Jay's alternative proposal of just keeping CreateTime in the message and having a config to control how far off the CreateTime can be from the broker time. We will think a bit more on this and Jiangjie will update the KIP wiki.
  • KIP-36: We discussed an alternative approach of introducing a new broker property to designate the rack. It's simpler and potentially can work in the case when the broker to rack mapping is maintaining externally. We need to make sure that we have an upgrade plan for this change. Allen will update the KIP wiki
2015-10-06
  • We only had the time to go through KIP-35. The consensus is that we will add a BrokerProtocolRequest that returns the supported versions for every type of requests. It's up to the client to decide how to use this. Magnus will update the KIP wiki with more details.
2015-09-22
  • KIP-31: Need to figure out how to evolve inter.broker.protocol.version with multiple protocol changes within the same release, mostly for people who are deploying from trunk. Becket will update the wiki.
  • KIP-32/KIP-33: Having both CreateTime and LogAppendTime per message adds significant overtime. There are a couple of possibilities to improve this. Becket will follow up on this.
  • LinkedIn has been testing SSL in MirrorMaker (SSL is only enabled in the producer). So far, MirrorMaker can keep up with the load. LinkedIn folks will share some of the performance results.
2015-09-14
  • KIP-28: Discussed the improved proposal including 2 layers of API (the higher layer is for streaming DSL), and stream time vs processor time. Ready for review.
  • KIP-31, KIP-32: (1) Discussed whether the timestamp should be from the client or the broker. (2) Discussed the migration path and whether this requires all consumers to upgrade before the new message format can be used. (3) Since this is too big a change, it will NOT be included in 0.9.0 release. Becket will update the wiki.
2015-08-18
  • client-side assignment strategy: We discussed concerns about rebalancing time due to metadata inconsistency, especially when lots of topics are subscribed. Will discuss a bit more on the mailing list. 
  • CopyCat data api: The discussions are in KAFKA-2367 for people who are interested.
  • 0.8.2.2: We want to make this a low risk bug fix release since 0.8.3 is coming. So, will only include a small number of critical and small fixes.
  • 0.8.3: The main features will be security and the new consumer. We will be cutting a release branch when the major pieces for these new features have been committed.
2015-08-11