THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
Log in
Skip to sidebar
Skip to main content
Apache Software Foundation
Spaces
Hit enter to search
Help
Online Help
Keyboard Shortcuts
Feed Builder
What’s new
What’s new
Available Gadgets
About Confluence
Log in
Apache Kafka
Pages
Blog
Space shortcuts
Retrospectives
Child pages
Index
Kafka Improvement Proposals
drafts
KIP-1 - Remove support of request.required.acks
KIP-2 - Refactor brokers to allow listening on multiple ports and IPs
KIP-3 - Mirror Maker Enhancement
KIP-4 - Command line and centralized administrative operations
KIP-5 - Broker Configuration Management
KIP-6 - New reassignment partition logic for rebalancing
KIP-7 - Security - IP Filtering
KIP-8 - Add a flush method to the producer API
KIP-12 - Kafka Sasl/Kerberos and SSL implementation
KIP-13 - Quotas
KIP-14 - Tools Standardization
KIP-15 - Add a close method with a timeout in the producer
KIP-16 - Automated Replica Lag Tuning
KIP-17 - Add HighwaterMarkOffset to OffsetFetchResponse
KIP-18 - JBOD Support
KIP-19 - Add a request timeout to NetworkClient
KIP-20 - Enable log preallocate to improve consume performance under windows and some old Linux file system
KIP-21 - Dynamic Configuration
KIP-22 - Expose a Partitioner interface in the new producer
KIP-23 - Add JSON/CSV output and looping options to ConsumerGroupCommand
KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request
KIP-25 - System test improvements
KIP-26 - Add Kafka Connect framework for data import/export
KIP-27 - Conditional Publish
KIP-28 - Add a processor client
KIP-29 - Add an IsrPropagateIntervalMs configuration to KafkaConfig
KIP-30 - Allow for brokers to have plug-able consensus and meta data storage sub systems
KIP-31 - Move to relative offsets in compressed message sets
KIP-32 - Add timestamps to Kafka message
KIP-33 - Add a time based log index
KIP-34 Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case
KIP-35 - Retrieving protocol version
KIP-36 Rack aware replica assignment
KIP-37 - Add Namespaces to Kafka
KIP-38: ZooKeeper Authentication
KIP-39 Pinning controller to broker
KIP-40: ListGroups and DescribeGroup
KIP-41: KafkaConsumer Max Records
KIP-42: Add Producer and Consumer Interceptors
KIP-43: Kafka SASL enhancements
KIP-44 - Allow Kafka to have a customized security protocol
KIP-45 - Standardize all client sequence interaction on j.u.Collection.
KIP-46: Self Healing Kafka
KIP-47 - Add timestamp-based log deletion policy
KIP-48 Delegation token support for Kafka
KIP-49 - Fair Partition Assignment Strategy
KIP-50 - Move Authorizer to o.a.k.common package
KIP-51 - List Connectors REST API
KIP-52: Connector Control APIs
KIP-53 - Add custom policies for reconnect attempts to NetworkdClient
KIP-54 - Sticky Partition Assignment Strategy
KIP-55: Secure Quotas for Authenticated Users
KIP-56: Allow cross origin HTTP requests on all HTTP methods
KIP-57 - Interoperable LZ4 Framing
KIP-58 - Make Log Compaction Point Configurable
KIP-59: Proposal for a kafka broker command
KIP-60 - Make Java client classloading more flexible
KIP-61: Add a log retention parameter for maximum disk space usage percentage
KIP-62: Allow consumer to send heartbeats from a background thread
KIP-63: Unify store and downstream caching in streams
KIP-64 -Allow underlying distributed filesystem to take over replication depending on configuration
KIP-65: Expose timestamps to Connect
KIP-66: Single Message Transforms for Kafka Connect
KIP-67: Queryable state for Kafka Streams
KIP-68 Add a consumed log retention before log retention
KIP-69 - Kafka Schema Registry
KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change
KIP-71: Enable log compaction and deletion to co-exist
KIP-72: Allow putting a bound on memory consumed by Incoming requests
KIP-73 Replication Quotas
KIP-74: Add Fetch Response Size Limit in Bytes
KIP-75 - Add per-connector Converters
KIP-76 Enable getting password from executable rather than passing as plaintext in config files
KIP-77: Improve Kafka Streams Join Semantics
KIP-78: Cluster Id
KIP-79 - ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer
KIP-80: Kafka Rest Server
KIP-81: Bound Fetch memory usage in the consumer
KIP-82 - Add Record Headers
KIP-83 - Allow multiple SASL authenticated Java clients in a single JVM process
KIP-84: Support SASL SCRAM mechanisms
KIP-85: Dynamic JAAS configuration for Kafka clients
KIP-86: Configurable SASL callback handlers
KIP-87 - Add Compaction Tombstone Flag
KIP-88: OffsetFetch Protocol Update
KIP-89: Allow sink connectors to decouple flush and offset commit
KIP-90 - Remove zkClient dependency from Streams
KIP-91 Provide Intuitive User Timeouts in The Producer
KIP-92 - Add per partition lag metrics to KafkaConsumer
KIP-93: Improve invalid timestamp handling in Kafka Streams
KIP-94 Session Windows
KIP-95: Incremental Batch Processing for Kafka Streams
KIP-96 - Add per partition metrics for in-sync and assigned replica count
KIP-97: Improved Kafka Client RPC Compatibility Policy
KIP-98 - Exactly Once Delivery and Transactional Messaging
KIP-99: Add Global Tables to Kafka Streams
KIP-100 - Relax Type constraints in Kafka Streams API
KIP-101 - Alter Replication Protocol to use Leader Epoch rather than High Watermark for Truncation
KIP-102 - Add close with timeout for consumers
KIP-103: Separation of Internal and External traffic
KIP-104: Granular Sensors for Streams
KIP-105: Addition of Recording Level for Sensors
KIP-106 - Change Default unclean.leader.election.enabled from True to False
KIP-107: Add deleteRecordsBefore() API in AdminClient
KIP-108: Create Topic Policy
KIP-109: Old Consumer Deprecation
KIP-110: Add Codec for ZStandard Compression
KIP-111: Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker.
KIP-112: Handle disk failure for JBOD
KIP-113: Support replicas movement between log directories
KIP-114: KTable state stores and improved semantics
KIP-115: Enforce offsets.topic.replication.factor upon __consumer_offsets auto topic creation
KIP-116: Add State Store Checkpoint Interval Configuration
KIP-117: Add a public AdminClient API for Kafka admin operations
KIP-118: Drop Support for Java 7
KIP-119: Drop Support for Scala 2.10 in Kafka 0.11
KIP-120: Cleanup Kafka Streams builder API
KIP-121: Add KStream peek method
KIP-122: Add Reset Consumer Group Offsets tooling
KIP-123: Allow per stream/table timestamp extractor
KIP-124 - Request rate quotas
KIP-Template
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback
KIP-127: Pluggable JAAS LoginModule configuration for SSL
KIP-126 - Allow KafkaProducer to split and resend oversized batches.
KIP-128: Add ByteArrayConverter for Kafka Connect
KIP-129: Streams Exactly-Once Semantics
KIP 130: Expose states of active tasks to KafkaStreams public API
KIP-131 - Add access to OffsetStorageReader from SourceConnector
KIP-132: Augment KStream.print to allow extra parameters in the printed string
KIP-133: Describe and Alter Configs Admin APIs
KIP-134: Delay initial consumer group rebalance
KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user
KIP-136: Add Listener name to SelectorMetrics tags
KIP-137: Enhance TopicCommand --describe to show topics marked for deletion
KIP-138: Change punctuate semantics
KIP-139: Kafka TestKit library
KIP-140: Add administrative RPCs for adding, deleting, and listing ACLs
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-143: Controller Health Metrics
KIP-144: Exponential backoff for broker reconnect attempts
KIP-146 - Classloading Isolation in Connect
KIP-145 - Expose Record Headers in Kafka Connect
KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner
KIP-150 - Kafka-Streams Cogroup
KIP-151 Expose Connector type in REST API
KIP-152 - Improve diagnostics for SASL authentication failures
KIP-153: Include only client traffic in BytesOutPerSec metric
KIP-154 Add Kafka Connect configuration properties for creating internal topics
KIP 155 - Add range scan for windowed state stores
KIP 156 Add option "dry run" to Streams application reset tool
KIP 157 - Add consumer config options to streams reset tool
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics
KIP-159: Introducing Rich functions to Streams
KIP-160: Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string
KIP-161: streams deserialization exception handlers
KIP-162 - Enable topic deletion by default
KIP-163: Lower the Minimum Required ACL Permission of OffsetFetch
KIP-164- Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics
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-167: Add interface for the state store restoration process
KIP-168: Add GlobalTopicCount and GlobalPartitionCount metrics per cluster
KIP-169 - Lag-Aware Partition Assignment Strategy
KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicy
KIP-171 - Extend Consumer Group Reset Offset for Stream Application
KIP 172: Add regular-expression topic support for sink connector
KIP-173: Add prefix to StreamsConfig to enable setting default internal topic configs
KIP-174 - Deprecate and remove internal converter configs in WorkerConfig
KIP-175: Additional '--describe' views for ConsumerGroupCommand
KIP-176: Remove deprecated new-consumer option for tools
KIP-178: Size-based log directory selection strategy
Old KIP-179 - Change ReassignPartitionsCommand to use AdminClient
KIP-180: Add a broker metric specifying the number of consumer group rebalances in progress
KIP-181: DescribeGroups Protocol Enhancement
KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines
KIP-179 - Change ReassignPartitionsCommand to use AdminClient
KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient
KIP-184: Rename LogCleaner and related classes to LogCompactor
KIP-185: Make exactly once in order delivery per partition the default producer setting
KIP-186: Increase offsets retention default to 7 days
KIP-177: Consumer perf tool should count rebalance time
KIP-187 - Add cumulative count metric for all Kafka rate metrics
KIP-188 - Add new metrics to support health checks
KIP-189: Improve principal builder interface and add support for SASL
KIP-190: Handle client-ids consistently between clients and brokers
KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern
KIP-192 : Provide cleaner semantics when idempotence is enabled
KIP-193: Add SchemaBuilder.from(Schema)
KIP-195: AdminClient.createPartitions
KIP-196: Add metrics to Kafka Connect framework
KIP-197 Connect REST API should include the connector type when describing a connector
KIP-198: Remove ZK dependency from Streams Reset Tool
KIP-199: Add Kafka Connect offset tool
KIP-201: Rationalising Policy interfaces
KIP-202 Move merge() from StreamsBuilder to KStream
KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule
KIP-204 : Adding records deletion operation to the new Admin Client API
KIP-205: Add all() and range() API to ReadOnlyWindowStore
KIP-206: Add support for UUID serialization and deserialization
KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change
KIP-208: Add SSL support to Kafka Connect REST interface
KIP-209 - Connection String Support
KIP-210 - Provide for custom error handling when Kafka Streams fails to produce
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-214: Add zookeeper.max.in.flight.requests config to the broker
KIP-215: Add topic regex support for Connect sinks
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-218: Make KafkaFuture.Function java 8 lambda compatible
KIP-219 - Improve quota communication
KIP-220: Add AdminClient into Kafka Streams' ClientSupplier
KIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint
KIP-222 - Add Consumer Group operations to Admin API
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer
KIP-224: Add configuration parameter `retries` to Streams API
KIP-225 - Use tags for consumer “records.lag” metrics
KIP-226 - Dynamic Broker Configuration
KIP-227: Introduce Incremental FetchRequests to Increase Partition Scalability
KIP-228 Negative record timestamp support
KIP-229: DeleteGroups API
KIP 230: Name Windowing Joins
KIP-231: Improve the Required ACL of ListGroups API
KIP-232: Detect outdated metadata using leaderEpoch and partitionEpoch
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-238: Expose Kafka cluster ID in Connect REST API
KIP-239 Add queryableStoreName() to GlobalKTable
KIP-240: AdminClient.listReassignments AdminClient.describeReassignments
KIP-241 KTable repartition with compacted Topics
KIP-242: Mask password in Kafka Connect Rest API response
KIP-243: Make ProducerConfig and ConsumerConfig constructors public
KIP-244: Add Record Header support to Kafka Streams Processor API
KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor
KIP-260: add primary join operation for Stream-Stream join (WIP)
KIP-246: Connect producers and consumers should inherit worker configs
KIP-247: Add public test utils for Kafka Streams
KIP-248 - Create New ConfigCommand That Uses The New AdminClient
KIP-249: Add Delegation Token Operations to KafkaAdminClient
KIP-250 Add Support for Quorum-based Producer Acknowledgment
KIP-251: Allow timestamp manipulation in Processor API
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-255 OAuth Authentication via SASL/OAUTHBEARER
KIP-256: Add RocksDB statistics via Streams metrics
KIP-257 - Configurable Quota Management
KIP-258: Allow to Store Record Timestamps in RocksDB
KIP-259: Improve Streams DSL Timestamp Propagation Semantics
KIP-261: Add Single Value Fetch in Window Stores
KIP-262: Metadata should include number of state stores for task
KIP-263: Allow broker to skip sanity check of inactive segments on broker startup
KIP-264: Add a consumer metric to record raw fetch size
KIP-265: Make Windowed Serde to public APIs
KIP-266: Fix consumer indefinite blocking behavior
KIP-267: Add Processor Unit Test Support to Kafka Streams Test Utils
KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade
KIP 269 Substitution Within Configuration Values
KIP-270 - A Scala Wrapper Library for Kafka Streams
KIP-271: Add NetworkClient redirector
KIP-272: Add API version tag to broker's RequestsPerSec metric
KIP-273 - Kafka to support using ETCD beside Zookeeper
KIP-274: Kafka Streams Skipped Records Metrics
KIP-275 - Indicate "isClosing" in the SinkTaskContext
KIP-276 Add StreamsConfig prefix for different consumers
KIP-277 - Fine Grained ACL for CreateTopics API
KIP-278 - Add version option to Kafka's commands
KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User
KIP-279: Fix log divergence between leader and follower after fast leader fail over
KIP-280: Enhanced log compaction
KIP-282: Add the listener name to the authentication context
KIP-283: Efficient Memory Usage for Down-Conversion
KIP-284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE
KIP-285: Connect Rest Extension Plugin
KIP-286: producer.send() should not block on metadata update
KIP-287: Support partition and processor expansion for stateful processing jobs
KIP-288: [DISCARDED] Consumer.poll() timeout semantic change and new waitForAssignment method
KIP-289: Improve the default group id behavior in KafkaConsumer
KIP-290: Support for Prefixed ACLs
KIP-292: Add transformValues() method to KTable
KIP-293 Add new metrics for consumer/replication fetch requests
KIP-291: Separating controller connections and requests from the data plane
KIP-294 - Enable TLS hostname verification by default
KIP-295: Add Streams Configuration Allowing for Optional Topology Optimization
KIP-296: Connector level configurability for client configs
KIP-NEXT: Get rid of unnecessary read lock
KIP-297: Externalizing Secrets for Connect Configurations
KIP-DRAFT: Error Handling in Connect
KIP-298: Error Handling in Connect
KIP-300: Add Windowed KTable API in StreamsBuilder
KIP-301: Schema Inferencing for JsonConverter
KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses
KIP-303: Add Dynamic Routing in Streams Sink
KIP-304: Connect runtime mode improvements for container platforms
KIP-305: Add Connect primitive number converters
KIP-306: Configuration for Delaying Response to Failed Client Authentication
KIP-307: Allow to define custom processor names with KStreams DSL
KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override
KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs
KIP-309: Add toUpperCase support to sasl.kerberos.principal.to.local rule
KIP-310: Add a Kafka Source Connector to Kafka Connect
KIP-311: Async processing with dynamic scheduling in Kafka Streams
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues
KIP-312: Add Overloaded StreamsBuilder Build Method to Accept java.util.Properties
KIP-314: KTable to GlobalKTable Bi-directional Join
KIP-316: Command-line overrides for ConnectDistributed worker properties
KIP-317: Add end-to-end data encryption functionality to Apache Kafka
KIP-318: Make Kafka Connect Source idempotent
KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplier
KIP-315: Stream Join Sticky Assignor
KIP-320: Allow fetchers to detect and handle log truncation
KIP-321: Update TopologyDescription to better represent Source and Sink Nodes
KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.
KIP-326: Schedulable KTable as Graph source
KIP-324: Add method to get metrics() in AdminClient
KIP-327: Add describe all topics API to AdminClient
KIP-325: Extend Consumer Group Command to Show Beginning Offsets
KIP-328: Ability to suppress updates for KTables
KIP-330: Add retentionPeriod in SessionBytesStoreSupplier
KIP-332: Update AclCommand to use AdminClient API
KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde
KIP-333: Add faster mode of rebalancing
KIP-334 - Include partitions in exceptions raised during consumer record deserialization/validation
KIP-335: Consider configurations for KafkaStreams
KIP-336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer
KIP-338 Support to exclude the internal topics in kafka-topics.sh command
KIP-339: Create a new IncrementalAlterConfigs API
KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file
KIP-341: Update Sticky Assignor's User Data Protocol
KIP-342: Add support for Custom SASL extensions in OAuthBearer authentication
KIP-343: Add a Controller Heartbeat Mechanism
KIP-344: The auto-generated client id should be passed to MetricsReporter
KIP-345: Introduce static membership protocol to reduce consumer rebalances
KIP-346 - Improve LogCleaner behavior on error
KIP-347: Enable batching in FindCoordinatorRequest
KIP-348 Deprecate null from SourceTask#poll()
KIP-349: Priorities for Source Topics
KIP-350: Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it
KIP-351: Add --under-min-isr option to describe topics command
KIP-352: Distinguish URPs caused by reassignment
KIP-353: Improve Kafka Streams Timestamp Synchronization
KIP-354: Add a Maximum Log Compaction Lag
KIP-356: Add withCachingDisabled() to StoreBuilder
KIP-356: Add KafkaConsumer fetch-error-rate and fetch-error-total metrics
KIP-357: Add support to list ACLs per principal
KIP-358: Migrate Streams API to Duration instead of long ms times
KIP-359: Verify leader epoch in produce requests
KIP-360: Improve reliability of idempotent/transactional producer
KIP-361: Add Consumer Configuration to Disable Auto Topic Creation
KIP-362: Support dynamic gap session window
KIP-363: Allow performance tools to print final results to output file
KIP-366: Make FunctionConversions deprecated
KIP-364: Remove implicit Materialized, Consumed and Produced
KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde
KIP-367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)
KIP-368: Allow SASL Connections to Periodically Re-Authenticate
KIP-369: Alternative Partitioner to Support "Always Round-Robin" Selection
KIP-370: Remove Orphan Partitions
KIP-371: Add a configuration to build custom SSL principal name
KIP-354: Time-based log compaction policy
KIP-372: Naming Repartition Topics for Joins and Grouping
KIP-373: Allow users to create delegation tokens for other users
KIP-374: Add '--help' option to all available Kafka CLI commands
KIP-375: Kafka Clients - make Metadata#TOPIC_EXPIRY_MS configurable
KIP-376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement
KIP-377: TopicCommand to use AdminClient
KIP-378: Enable Dependency Injection for Kafka Streams handlers
KIP-379: Multiple Consumer Group Management
KIP-380: Detect outdated control requests and bounced brokers using broker generation
KIP-381: Connect: Tell about records that had their offsets flushed in callback
KIP-382: MirrorMaker 2.0
KIP-383: Pluggable interface for SSL Factory
KIP-384: Add config for incompatible changes to persistent metadata
KIP-385: Avoid throwing away prefetched data
KIP-386: Standardize on Min/Avg/Max metrics' default value
KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer
KIP-388: Add observer interface to record request and response
KIP-389: Introduce a configurable consumer group size limit
KIP-390: Support Compression Level
KIP-391: Allow Producing with Offsets for Cluster Replication [Discarded]
KIP-392: Allow consumers to fetch from closest replica
KIP-393: Time windowed serde to properly deserialize changelog input topic
KIP-394: Require member.id for initial join group request
KIP-395: Encypt-then-MAC Delegation token metadata
KIP-396: Add Reset/List Offsets Operations to AdminClient
KIP-397: Add methods to override fetch offsets based on timestamp
KIP-398: Support reading trust store from classpath
KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions
KIP-400: Improve exit status in case of errors in ConsoleProducer
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting
KIP-402: Improve fairness in SocketServer processors
KIP-403: Increase ProducerPerformance precision by using nanoTime
KIP-404: Add Kafka Connect configuration parameter for disabling WADL output on OPTIONS request
KIP-405: Kafka Tiered Storage
KIP-406: GlobalStreamThread should honor custom reset policy
KIP-407: Kafka Connect support override worker kafka api configuration with connector configuration that post by rest api
KIP-NEXT: Add support of quota configuration in the KafkaAdminClient
KIP-408: Add Asynchronous Processing To Kafka Streams
KIP-409: Allow creating under-replicated topics and partitions
KIP-410: Add metric for request handler thread pool utilization by request type
KIP-411: Make default Kafka Connect worker task client IDs distinct
KIP-412: Extend Admin API to support dynamic application log levels
KIP-414: Expose Embedded ClientIds in Kafka Streams
KIP-416: Notify SourceTask of ACK'd offsets, metadata
KIP-415: Incremental Cooperative Rebalancing in Kafka Connect
KIP-417: Allow JmxTool to connect to a secured RMI port
KIP-418: A method-chaining way to branch KStream
KIP-419: Safely notify Kafka Connect SourceTask is stopped
KIP-420: Add Single Value Fetch in Session Stores
KIP-706: Add method "Producer#send" to return CompletionStage instead of Future
KIP-531: Drop support for Scala 2.11 in Kafka 2.5
KIP-421: Automatically resolve external configurations.
KIP-422: Add support for client quota configuration in the Kafka Admin Client
KIP-423: Add JoinReason to Consumer Join Group Protocol
KIP-424: Allow suppression of intermediate events based on wall clock time
KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers
KIP-426: Persist Broker Id to Zookeeper
KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)
KIP-428: Add in-memory window store
KIP-429: Kafka Consumer Incremental Rebalance Protocol
KIP-430 - Return Authorized Operations in Describe Responses
KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter
KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation
KIP-433: Block old clients on brokers
KIP-434: Add Replica Fetcher and Log Cleaner Count Metrics
KIP-435: Internal Partition Reassignment Batching
KIP-436: Add a metric indicating start time
KIP-437: Custom replacement for MaskField SMT
KIP-438: Expose task, connector IDs in Connect API
KIP-439: Cleanup built-in Store interfaces
KIP-440: Extend Connect Converter to support headers
KIP-441: Smooth Scaling Out for Kafka Streams
KIP-446: Add changelog topic configuration to KTable suppress
KIP-442: Return to default max poll interval in Streams
KIP-443: Return to default segment.ms and segment.index.bytes in Streams repartition topics
KIP-444: Augment metrics for Kafka Streams
KIP-445: In-memory Session Store
KIP-447: Producer scalability for exactly once semantics
KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils
KIP-449: Add connector contexts to Connect worker logs
KIP-450: Sliding Window Aggregations in the DSL
KIP-451: Make TopologyTestDriver output iterable
KIP-452: Tool to view cluster status
KIP-454: Expansion of the ConnectClusterState interface
KIP-455: Create an Administrative API for Replica Reassignment
KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver
KIP-457: Add DISCONNECTED status to Kafka Streams
KIP-458: Connector Client Config Override Policy
KIP-459: Improve KafkaStreams#close
KIP-460: Admin Leader Election RPC
KIP-462: Use local thread id for KStreams
KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder
KIP-461 - Improve Replica Fetcher behavior at handling partition failure
KIP-464: Defaults for AdminClient#createTopic
KIP-465: Add Consolidated Connector Endpoint to Connect REST API
KIP-453: Add close() method to RocksDBConfigSetter
KIP-466: Add support for List<T> serialization and deserialization
KIP-467: Augment ProduceResponse error messaging for specific culprit records
KIP-468: Avoid decompression of record when validate record at server in the scene of inPlaceAssignment .
KIP-469: Pre-registration support for static members
KIP-470: TopologyTestDriver test input and output usability improvements
KIP-471: Expose RocksDB Metrics in Kafka Streams
KIP-472: [STREAMS] Add partition time field to RecordContext
KIP-473: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers
KIP-474: To deprecate WindowStore#put(key, value)
KIP-475: New Metrics to Measure Number of Tasks on a Connector
KIP-476: Add Java AdminClient Interface
KIP-477: Add PATCH method for connector config in Connect REST API
KIP-478 - Strongly typed Processor API
KIP-479: Add StreamJoined config object to Join
KIP-480: Sticky Partitioner
KIP-481: SerDe Improvements for Connect Decimal type in JSON
KIP-483: Add Broker Version API in Admin Client
KIP-484: Expose metrics for group and transaction metadata loading duration
KIP-497: Add inter-broker API to alter ISR
KIP-482: The Kafka Protocol should Support Optional Tagged Fields
KIP-485: Make topic optional when using through() operations in DSL
KIP-486: Support custom way to load KeyStore and TrustStore
KIP-487: Client-side Automatic Topic Creation on Producer
KIP-488: Clean up Sum,Count,Total Metrics
489: Kafka Consumer Record Latency Metric
KIP-490: New metric to count offsets expired without being consumed by a consumer group
KIP-491: Preferred Leader Deprioritized List (Temporary Blacklist)
KIP-492: Add java security providers in Kafka Security config
KIP-494: Connect REST Endpoint to get Transformations (SMTs)
KIP-495: Dynamically Adjust Log Levels in Connect
KIP-496: Administrative API to delete consumer offsets
KIP-498: Add client-side configuration for maximum response size to protect against OOM
KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum
KIP-501 Avoid out-of-sync or offline partitions when follower fetch requests are not processed in time
KIP-499 - Unify connection name flag for command line tool
KIP-502: Connect Task Method Signature to be More Specific for Developers
KIP-503: Add metric for number of topics marked for deletion
KIP-504 - Add new Java Authorizer Interface
KIP-505: Add new public method to only update assignment metadata in consumer
KIP-506: Allow setting SCRAM password via Admin interface
KIP-507: Securing Internal Connect REST Endpoints
KIP-508: Make Suppression State Queriable
KIP-509: Rebalance and restart Producers
KIP-510: Metrics library upgrade
KIP-511: Collect and Expose Client's Name and Version in the Brokers
KIP-512:Adding headers to RecordMetaData
KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams
KIP-532: Broker Consumer Lag metrics in size and time
KIP-514: Add a bounded flush() API to Kafka Producer
KIP-515: Enable ZK client to use the new TLS supported authentication
KIP-534: Retain tombstones and transaction markers for approximately delete.retention.ms milliseconds
KIP-516: Topic Identifiers
KIP-517: Add consumer metrics to observe user poll behavior
KIP-518: Allow listing consumer groups per state
KIP-519: Make SSL context/engine configuration extensible
KIP-520: Add overloaded Consumer#committed for batching partitions
KIP-521: Enable redirection of Connect's log4j messages to a file by default
KIP-522: Update BrokerApiVersionsCommand to use AdminClient
KIP-523: Add KStream#toTable to the Streams DSL
KIP-524: Allow users to choose config source when describing configs
KIP-525 - Return topic metadata and configs in CreateTopics response
KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics
KIP-527: Add VoidSerde to Serdes
KIP-528: Deprecate PartitionGrouper configuration and interface
KIP-530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'
KIP-533: Add default api timeout to AdminClient
KIP-X: Introduce a cooperative consumer processing semantic
KIP-535: Allow state stores to serve stale reads during rebalance
KIP-536: Propagate broker start time to Admin API
KIP-537: Increase default zookeeper session timeout
KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type
KIP-539: Implement mechanism to flush out records in low traffic suppression buffers
KIP-540: Implement per key stream time tracking
KIP-541: Create a fetch.max.bytes configuration for the broker
KIP-542: Partition Reassignment Throttling
KIP-543: Expand ConfigCommand's non-ZK functionality
KIP-545: support automated consumer offset sync across clusters in MM 2.0
KIP-XX: Decouple Kafka Streams Scalability from Physical partition
KIP-544: Make metrics exposed via JMX configurable
KIP-546: Add Client Quota APIs to the Admin Client
KIP-547: Extend ConsumerInterceptor to allow modification of Consumer Commits
KIP-548 Add Option to enforce rack-aware custom partition reassignment execution
KIP-549: Surface Consumer's Metadata in KafkaAdminClient#describeConsumerGroups
KIP-565: Using AclCommand,avoid call the global method loadcache in SimpleAclAuthorizer
KIP-550: Mechanism to Delete Stray Partitions on Broker
KIP-551: Expose disk read and write metrics
KIP-553: Disable all SSL protocols except TLSV1.2 by default.
KIP-555: Deprecate Direct Zookeeper access in Kafka Administrative Tools
KIP-557: Add emit on change support for Kafka Streams
KIP-558: Track the set of actively used topics by connectors in Kafka Connect
KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies
KIP-560: Auto infer external topic partitions in stream reset tool
KIP-561: Regex Support for ConsumerGroupCommand
KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance
KIP-564: Add new cached authorizer:change the dim of cache
KIP-563: Add 'tail -n' feature for ConsoleConsumer
KIP-566: Add rebalance callbacks to ConsumerInterceptor
KIP-567: Kafka Cluster Audit
KIP-568: Support RPC message type 'double'
KIP-DRAFT: Handle errors for data inside put method of a sink connector
KIP-568: Explicit rebalance triggering on the Consumer
KIP-569: DescribeConfigsResponse - Update the schema to include additional metadata information of the field
KIP-570: Add leader epoch in StopReplicaRequest
KIP-571: Add option to force remove members in StreamsResetter
KIP-572: Improve timeouts and retries in Kafka Streams
KIP-573: Enable TLSv1.3 by default
KIP-574: CLI Dynamic Configuration with file input
KIP-575: build a Kafka-Exporter by Java
KIP-576: Support dynamic update of more broker configs related to replication
KIP 577: Allow HTTP Response Headers to be Configured for Kafka Connect
KIP-578: Add configuration to limit number of partitions
KIP-579: new exception on min.insync.replicas > replication.factor
KIP-580: Exponential Backoff for Kafka Clients
KIP-581: Value of optional null field which has default value
KIP-582: Add a "continue" option for Kafka Connect error handling
KIP-583: add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker
KIP-584: Versioning scheme for features
KIP-585: Filter and Conditional SMTs
KIP-586: Deprecate commit records without record metadata
KIP-587: Suppress detailed responses for handled exceptions in security-sensitive environments
KIP-588: Allow producers to recover gracefully from transaction timeouts
KIP-590: Redirect Zookeeper Mutation Protocols to The Controller
KIP-589 Add API to update Replica state in Controller
KIP-591: Add Kafka Streams config to set default state store
KIP-592: MirrorMaker 1.0 should replicate topics from earliest
KIP-593: Enable --if-exists and --if-not-exists for AdminClient in TopicCommand
KIP-596: Safely abort Producer transactions during application shutdown
KIP-594: Expose output topic names from TopologyTestDriver
KIP-595: A Raft Protocol for the Metadata Quorum
KIP-597: MirrorMaker2 internal topics Formatters
KIP-598: Augment TopologyDescription with store and source / sink serde information
KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations
KIP-601: Configurable socket connection timeout in NetworkClient
KIP-602: Change default value for client.dns.lookup
KIP-603: Change `ConfigEntry` value to use optional fields
KIP-605: Expand Connect Worker Internal Topic Settings
KIP-554: Add Broker-side SCRAM Config API
KIP-604: Remove ZooKeeper Flags from the Administrative Tools
KIP-606: Add Metadata Context to MetricsReporter
KIP-608 - Expose Kafka Metrics in Authorizer
KIP-609: Use Pre-registration and Blocking Calls for Better Transaction Efficiency
KIP-607: Add Metrics to Kafka Streams to Report Properties of RocksDB
KIP-610: Error Reporting in Sink Connectors
KIP-611: Improved Handling of Abandoned Connectors and Tasks
KIP-612: Ability to Limit Connection Creation Rate on Brokers
KIP-614: Add Prefix Scan support for State Stores
KIP-613: Add end-to-end latency metrics to Streams
KIP-615: add ConstrainedCooperativeStickyAssignor
KIP-616: Rename implicit Serdes instances in kafka-streams-scala
KIP-617: Allow Kafka Streams State Stores to be iterated backwards
KIP-618: Exactly-Once Support for Source Connectors
KIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig
KIP-619: Add internal topic creation support
KIP-621: Deprecate and replace DescribeLogDirsResult.all() and .values()
KIP-622: Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext
KIP-623: Add "internal-topics" option to streams application reset tool
KIP-624: Consolidate Offset Validation into Fetch Protocol
KIP-625: Richer encodings for integral-typed protocol fields
KIP-626: Rename StreamsConfig config variable name
KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents
KIP-628: ConsumerPerformance's multi-thread implementation
KIP-629: Use racially neutral terms in our codebase
KIP-630: Kafka Raft Snapshot
KIP-631: The Quorum-based Kafka Controller
KIP-634: Complementary support for headers and record metadata in Kafka Streams DSL
KIP-636: Make RPC error codes and messages tagged fields
KIP-637: Include min.insync.replicas in MetadataResponse to make Producer smarter in partitioning events
KIP-638: Deprecate DescribeLogDirsResponse.[LogDirInfo, ReplicaInfo]
KIP-639: Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics
KIP-640: Add log compression analysis tool
KIP-641 An new java interface to replace 'kafka.common.MessageReader'
KIP-642: Dynamic quorum reassignment
KIP-644: Support sources which can't give out changed data in kafka connect
KIP-645: Replace Windows with a proper interface
KIP-646 Serializer API should support ByteBuffer
KIP-647: Add ability to handle late messages in streams-aggregation
KIP-648: Renaming getter method for Interactive Queries
KIP-649: Dynamic Client Configuration
KIP-650: Enhance Kafkaesque Raft semantics
KIP-656: MirrorMaker2 Exactly-once Semantics
KIP-651 - Support PEM format for SSL certificates and private key
KIP-653: Upgrade log4j to log4j2
KIP-654: Aborted transaction with non-flushed data should throw a non-fatal exception
KIP-632: Add DirectoryConfigProvider
KIP-655: Windowed Distinct Operation for Kafka Streams API
KIP-657: Add Customized Kafka Streams Logo
[DISCARD] KIP-658 Deprecate all setters of Headers
KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size
KIP-660: Pluggable ReplicaPlacer
KIP-661: Expose task configurations in Connect REST API
KIP-662: Throw Exception when Source Topics of a Streams App are Deleted
KIP-663: API to Start and Shut Down Stream Threads
KIP-664: Provide tooling to detect and abort hanging transactions
KIP-665: Kafka Connect Hash SMT
KIP-666: Add Instant-based methods to ReadOnlySessionStore
KIP-667: Remove deprecated methods from ReadOnlyWindowStore
KIP-668: Expose REST endpoint to list converter plugins
KIP-669: Preserve Source Partition in Kafka Streams from context
KIP-670: Add ConsumerGroupCommand to delete static members
KIP-671: Introduce Kafka Streams Specific Uncaught Exception Handler
KIP-672: Introduce Kafka Streams Specific Uncaught Exception Handler
KIP-673: Emit JSONs with new auto-generated schema
KIP-674: Metric Reporter to Aggregate Metrics in Kafka Streams
KIP-675: Convert KTable to a KStream using the previous value
KIP-676: Respect logging hierarchy
KIP-677: migrating Topology methods to the Builder pattern (WIP)
KIP-679: Producer will enable the strongest delivery guarantee by default
KIP-678: New Kafka Connect SMT for plainText => Struct(or Map) with Regex
KIP-680: TopologyTestDriver should not require a Properties argument
KIP-681: Rename master key in delegation token feature
KIP-682: Connect TimestampConverter support for multiple fields and multiple input formats
KIP-683: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSON string
KIP-684 - Support mutual TLS authentication on SASL_SSL listeners
KIP-685: Loosen permission for listing reassignments
KIP-686: API to ensure Records policy on the broker
KIP-695: Further Improve Kafka Streams Timestamp Synchronization
KIP-691: Enhance Transactional Producer Exception Handling
KIP-687: Automatic Reloading of Security Store
KIP-NEXT: Support dynamic update of delete.topic.enable config
KIP-688: Support dynamic update of delete.topic.enable config
KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams
KIP-689: Extend `StreamJoined` to allow more store configs
KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention
KIP-xxx: Cache the UpdateMetadata requests in controller
KIP-694: Support Reducing Partitions for Topics
KIP-692: Make AdminClient value object constructors public
KIP-693: Client-side Circuit Breaker for Partition Write Errors
KIP-X: Native TopK support in Kafka Streams
KIP-696: Update Streams FSM to clarify ERROR state meaning
KIP-697: Stricter parsing of addresses in configs
KIP-699: Update FindCoordinator to resolve multiple Coordinators at a time
KIP-700: Add Describe Cluster API
KIP-701: Add--override option to bin/connect-distributed.sh
KIP-702: The control plane needs to force the validation of requests from the controller
KIP-703: Add a metrics for reporting idle connections closed
KIP-704: Send a hint to the partition leader to recover the partition
KIP-705: Selectively Disable Topology Optimizations
KIP-707: The future of KafkaFuture
KIP-708: Rack aware StandbyTask assignment for Kafka Streams
KIP-709: Extend OffsetFetch requests to accept multiple group ids.
KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters
KIP-711 Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException
KIP-712: Shallow Mirroring
KIP-713: Validation of Enums in configuration
KIP-714: Client metrics and observability
KIP-715: Expose Committed offset in streams
KIP-716: Allow configuring the location of the offset-syncs topic with MirrorMaker2
KIP-717: Deprecate batch-size config from console producer
KIP-718: Make KTable Join on Foreign key unopinionated
KIP-719: Deprecate Log4J Appender
KIP-720: Deprecate MirrorMaker v1
KIP-721: Enable connector log contexts in Connect Log4j configuration
KIP-722: Enable connector client overrides by default
KIP-723: Add socket.tcp.no.delay property to Kafka Config
KIP-724: Drop support for message formats v0 and v1
KIP-725: Streamlining configurations for WindowedSerializer and WindowedDeserializer.
KIP-726: Make the "cooperative-sticky, range" as the default assignor
KIP-727: Add --under-preferred-replica-partitions option to describe topics command
KIP-633: Deprecate 24-hour Default Grace Period for Windowed Operations in Streams
KIP-728: Introduce the RESTORING state to the KafkaStreams state machine
KIP-729: Custom validation of records on the broker prior to log append
KIP-730: Producer ID generation in KRaft mode
KIP-731: Record Rate Limiting for Kafka Connect
KIP-732: Deprecate eos-alpha and replace eos-beta with eos-v2
KIP-733: change Kafka Streams default replication factor config
KIP-734: Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp
KIP-735: Increase default consumer session timeout
KIP-736: Report the true end to end fetch latency
KIP-738: Removal of Connect's internal converter properties
KIP-737: Add canTrackSource to ReplicationPolicy
KIP-739: Block Less on KafkaProducer#send
KIP-740: Clean up public API in TaskId
KIP-741: Change default serde to be null
KIP-743: Remove config value 0.10.0-2.4 of Streams built-in metrics version config
KIP-744: Migrate TaskMetadata and ThreadMetadata to an interface with internal implementation
KIP-751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0)
KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)
KIP-746: Revise KRaft Metadata Records
KIP-745: Connect API to restart connector and tasks
KIP-748: Add Broker Count Metrics
KIP-749: Add --files and --file-separator options to the ConsoleProducer
KIP-752: Support --bootstrap-server in ReplicaVerificationTool
KIP-753: ACL authentication, Host field support IP network segment
KIP-754: Make Scala case class's final
KIP-755: Add new AUTO_CREATE ACL for auto topic creation
KIP-756: Move StreamsResetter tool outside of core
KIP-757: Topic metadata
KIP-758: Remove list of latest producer append information for broker
KIP-759: Unneeded repartition canceling
KIP-760: Minimum value for segment.ms and segment.bytes
KIP-761: Add Total Blocked Time Metric to Streams
KIP-762: Delete Committed Connect Records
KIP-763: Range queries with open endpoints
KIP-764: Configurable backlog size for creating Acceptor
KIP-765: Introduce new SlidingWindow type for [start,end] time
KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore
KIP-767: Connect Latency Metrics
KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC
KIP-769: Connect APIs to list all connector plugins and retrieve their configuration definitions
KIP-770: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"
KIP-772: Encrypt KRaft Metadata Secrets at Rest
KIP-773: Differentiate consistently metric latency measured in millis and nanos
KIP-774: Deprecate public access to Admin client's *Result constructors
KIP-775: Custom partitioners in foreign key joins
KIP-776: Add Consumer#peek for debugging/tuning
KIP-777: Improved testability for Admin client
KIP-778: KRaft to KRaft Upgrades
KIP-779: Allow Source Tasks to Handle Producer Exceptions
KIP-780: Support fine-grained compression options
KIP-781: Improve MirrorMaker2's client configuration
KIP-782: Expandable batch size in producer
KIP-783: Add TaskId field to StreamsException
KIP-784: Add top-level error code field to DescribeLogDirsResponse
KIP-785: Automatic storage formatting
KIP-786: Emit Metric Client Quota Values
KIP-789: Use localhost:9092 as default bootstrap-server/broker-list in client tools
KIP-787: MM2 manage Kafka resources with custom Admin implementation.
KIP-788: Allow configuring num.network.threads per listener
KIP-796: Interactive Query v2
KIP-791: Add Record Metadata to State Store Context
KIP-792: Add "generation" field into consumer protocol
KIP-793: Allow sink connectors to be used with topic-mutating SMTs
KIP-794: Strictly Uniform Sticky Partitioner
KIP-795: Add public APIs for AbstractCoordinator
KIP-797: Accept duplicate listener on port for IPv4/IPv6
KIP-798: Add possibility to write kafka headers in Kafka Console Producer
KIP-799: Align behaviour for producer callbacks with documented behaviour
KIP-800: Add reason to JoinGroupRequest and LeaveGroupRequest
KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata
KIP-802: Validation Support for Kafka Connect SMT and Converter Options
KIP-803: Add Task ID and Connector Name to Connect Task Context
KIP-804: OfflinePartitionsCount Tagged by Topic
KIP-805: Add range and scan query over kv-store in IQv2
KIP-806: Add session and window query over kv-store in IQv2
KIP-807: Refactor KafkaStreams exposed metadata hierarchy
KIP-808: Add support for different unix precisions in TimestampConverter SMT
KIP-809: Support live upgrades with dynamic addition/removal of modular topologies
KIP-810: Allow producing records with null values in Kafka Console Producer
KIP-NEXT: Add lowest acknowledged offset to BrokerHeartbeatResponse
KIP-811: Add config repartition.purge.interval.ms to Kafka Streams
KIP-812: Introduce another form of the `KafkaStreams.close()` API that forces the member to leave the consumer group
KIP-815: Support max-timestamp in GetOffsetShell
KIP-813: Shareable State Stores
KIP-814: Static membership protocol should let the leader skip assignment
KIP-816: Topology changes without local state reset
KIP-817: Fix inconsistency in dynamic application log levels
KIP-818: Introduce cache-size-bytes-total Task Level Metric
KIP-819: Merge multiple KStreams in one operation
KIP-820: Extend KStream process with new Processor API
KIP-821: Connect Transforms support for nested structures
KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols
KIP-823: Update Admin::describeConfigs to allow fetching specific configurations
KIP-824: Allowing dumping segmentlogs limiting the batches in the output
KIP-825: introduce a new API to control when aggregated results are produced
KIP-826: Define platforms supported
KIP-827: Expose log dirs total and usable space via Kafka API
KIP-828: Add the corresponding validator to the configuration where the validator is missing
KIP-829: (console-consumer) add print.topic property
KIP-830: Allow disabling JMX Reporter
KIP-831: Add metric for log recovery progress
KIP-832: Allow creating a producer/consumer using a producer/consumer config
KIP-833: Mark KRaft as Production Ready
KIP-834: Pause / Resume KafkaStreams Topologies
KIP-835: Monitor KRaft Controller Quorum Health
KIP-837: Allow MultiCasting a Result Record.
KIP-836: Expose replication information of the cluster metadata
[DRAFT] KIP-821: Connect Transforms support for nested structures (JsonPath-based draft)
KIP-841: Fenced replicas should not be allowed to join the ISR in KRaft
KIP-839: Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams
KIP-840: Config file option for MessageReader/MessageFormatter in ConsoleProducer/ConsoleConsumer
KIP-842: Add richer group offset reset mechanisms
KIP-843: Adding addMetricIfAbsent method to Metrics
KIP-844: Transactional State Stores
KIP-845: 'HasField' predicate for kafka connect
KIP-846: Source/sink node metrics for Consumed/Produced throughput in Streams
KIP-848: The Next Generation of the Consumer Rebalance Protocol
KIP-847: Add ProducerIdCount metrics
KIP-849: Expose logdirs total and usable space via kafka-log-dirs.sh
KIP-850: REST API for filtering Connector plugins by type
KIP-851: Add requireStable flag into ListConsumerGroupOffsetsOptions
KIP-852: Optimize calculation of size for log in remote tier
KIP-853: KRaft Controller Membership Changes
KIP-854 Separate configuration for producer ID expiry
KIP-855: Add schema.namespace parameter to SetSchemaMetadata SMT in Kafka Connect
KIP-857: Streaming recursion in Kafka Streams
KIP-856: KRaft Disk Failure Recovery
KIP-858: Handle JBOD broker disk failure in KRaft
KIP-NEXT: Insert Title Here
KIP-859: Add Metadata Log Processing Error Related Metrics
KIP-860: Add client-provided option to guard against replication factor change during partition reassignments
KIP-862: Self-join optimization for stream-stream joins
KIP-861: Add BytesIn/BytesOut per listener metrics
KIP-863: Reduce CompletedFetch#parseRecord() memory copy
KIP-864: Add End-To-End Latency Metrics to Connectors
KIP-865: Support --bootstrap-server in kafka-streams-application-reset
KIP-868 Metadata Transactions
KIP-866 ZooKeeper to KRaft Migration
KIP-869: Improve Streams State Restoration Visibility
KIP-870: Retention policy based on record event time
KIP-871: Fix ByteBufferSerializer#serialize(String, ByteBuffer) compatible problem
KIP-872: Add Serializer#serializeToByteBuffer() to reduce memory copying
KIP-873: ExceptionHandlingDeserializer, RetryDeserializer, PipeSerializer, PipeDeserializer
KIP-874: TopicRoundRobinAssignor
KIP-875: First-class offsets support in Kafka Connect
KIP-877: Mechanism for plugins and connectors to register metrics
KIP-876: Time based cluster metadata snapshots
KIP-878: Internal Topic Autoscaling for Kafka Streams
KIP-879: Multi-level Rack Awareness
KIP-880: X509 SAN based SPIFFE URI ACL within mTLS Client Certificates
KIP-881: Rack-aware Partition Assignment for Kafka Consumers
KIP-882: Kafka Connect REST API configuration validation timeout improvements
KIP-883: Add isDeleted flag when stopping a connector
KIP-884: Add config to configure KafkaClientSupplier in Kafka Streams
KIP-885: Expose Broker's Name and Version to Clients
KIP-886: Add Client Producer and Consumer Builders
KIP-887: Add ConfigProvider to make use of environment variables
KIP-888: Batch describe ACLs and describe client quotas
KIP-889: Versioned State Stores
KIP-890: Transactions Server-Side Defense
KIP-891: Running multiple versions of a connector
KIP-892: Transactional Semantics for StateStores
KIP-893: The Kafka protocol should support nullable structs
KIP-894: Use incrementalAlterConfigs API for syncing topic configurations
KIP-896: Remove old client protocol API versions in Kafka 4.0
KIP-895: Dynamically refresh partition count of __consumer_offsets
KIP-897: Publish a single kafka (aka core) Maven artifact in Apache Kafka 4.0
KIP-898: Modernize Connect plugin discovery
KIP-899: Allow producer and consumer clients to rebootstrap
KIP-900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers
KIP-901: Add connectorDeleted flag when stopping tasks
KIP-902: Upgrade Zookeeper to 3.8.2
KIP-903: Replicas with stale broker epoch should not be allowed to join the ISR
KIP-904: Kafka Streams - Guarantee subtractor is called before adder if key has not changed
KIP-905: Broker interceptors
KIP-906: Tools migration guidelines
KIP-907: Add Boolean Serde to public interface
KIP-908: Add description field to connector configuration
KIP-909: DNS Resolution Failure Should Not Fail the Clients
KIP-911: Add source tag to MirrorSourceConnector metrics
KIP-912: Support decreasing send's max block time without worrying about metadata's fetch
KIP-913: add new method to provide possibility for accelerate first record's sending
KIP-914: DSL Processor Semantics for Versioned Stores
KIP-915: Txn and Group Coordinator Downgrade Foundation
KIP-910: Update Source offsets for Source Connectors without producing records
KIP-916: MM2 distributed mode flow log context
KIP-917: Additional custom metadata for remote log segment
KIP-918: MM2 Topic And Group Listener
KIP-919: Allow AdminClient to Talk Directly with the KRaft Controller Quorum and add Controller Registration
KIP-920: Support upgrading KRaft MetadataVersion based on a static config
KIP-921: OpenJDK CRaC support
KIP-922: Add the traffic metric of the partition dimension
KIP-923: Add A Grace Period to Stream Table Join
KIP-925: Rack aware task assignment in Kafka Streams
KIP-926: introducing acks=min.insync.replicas config
KIP-927: Improve the kafka-metadata-quorum output
KIP-928: Making Kafka resilient to log directories becoming full
KIP-929 : Observer Replicas
KIP-930: Rename ambiguous Tiered Storage Metrics
KIP-931: Flag to ignore unused message attribute field
KIP-932: Queues for Kafka
KIP-934: Add DeleteTopicPolicy
KIP-935: Extend AlterConfigPolicy with existing configurations
KIP-933: Publish metrics when source connector fails to poll data
KIP-936: Throttle number of active PIDs
KIP-937: Improve Message Timestamp Validation
KIP-938: Add more metrics for measuring KRaft performance
KIP-939: Support Participation in 2PC
KIP-940: Broker extension point for validating record contents at produce time
KIP-941: Range queries to accept null lower and upper bounds
KIP-942: Add Power(ppc64le) support
KIP-944: Support async runtimes in consumer
KIP-943: Add independent “offset.storage.segment.bytes” for connect-distributed.properties
KIP-945: Update threading model for Consumer
KIP-946: Modify exceptions thrown by Consumer APIs
KIP-947: Add support for consumer group protocol in Consumer
KIP-948: Allow custom prefix for internal topic names in Kafka Streams
KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy
KIP-950: Tiered Storage Disablement
KIP-951: Leader discovery optimisations for the client
KIP-952: Regenerate segment-aligned producer snapshots when upgrading to a Kafka version supporting Tiered Storage
KIP-953: partition method to be overloaded to accept headers as well.
KIP-954: expand default DSL store configuration to custom types
KIP-924: customizable task assignment for Streams
KIP-955: Add stream-table join on foreign key
KIP-956 Tiered Storage Quotas
KIP-957: Support Async runtimes
KIP-958: Tiered Storage Metrics
KIP-959: Add BooleanConverter to Kafka Connect
KIP-960: Support single-key_single-timestamp interactive queries (IQv2) for versioned state stores
KIP-962: Relax non-null key requirement in Kafka Streams
KIP-963: Additional metrics in Tiered Storage
KIP-964: Have visibility when produce requests become "async"
KIP-965: Support disaster recovery between clusters by MirrorMaker
KIP-966: Eligible Leader Replicas
KIP-967: Support custom SSL configuration for Kafka Connect RestServer
KIP-969: Support range interactive queries (IQv2) for versioned state stores
KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores
KIP-970: Deprecate and remove Connect's redundant task configurations endpoint
KIP-971: Expose replication-record-lag MirrorMaker2 metric
KIP-972: Add the metric of the current running version of kafka
KIP-973: Expose per topic replication rate metrics
KIP-974: Docker Image for GraalVM based Native Kafka Broker
KIP-975: Docker Image for Apache Kafka
KIP-976: Cluster-wide dynamic log adjustment for Kafka Connect
KIP-977: Partition-Level Throughput Metrics
KIP-978: Allow dynamic reloading of certificates with different DN / SANs
KIP-979: Allow independently stop KRaft processes
KIP-980: Allow creating connectors in a stopped state
KIP-982: Access SslPrincipalMapper and kerberosShortNamer in Custom KafkaPrincipalBuilder
KIP-981: Manage Connect topics with custom implementation of Admin
KIP-983: Full speed async processing during rebalance
KIP-984: Add pluggable compression interface to Kafka
KIP-985: Add reverseRange and reverseAll query over kv-store in IQv2
KIP-986: Cross-Cluster Replication
KIP-988: Streams Standby Update Listener
KIP-989: RocksDB Iterator Metrics
KIP-995: Allow users to specify initial offsets while creating connectors
KIP-987: Connect Static Assignments
KIP-990: Capability to PAUSE Tasks on DeserializationException
KIP-996: Pre-Vote
KIP-991: Allow DropHeaders SMT to drop headers by wildcard/regexp
KIP-992: Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery
KIP-994: Minor Enhancements to ListTransactions and DescribeTransactions APIs
KIP-993: Allow restricting files accessed by File and Directory ConfigProviders
KIP-997: update WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery
KIP-998: Give ProducerConfig(props, doLog) constructor protected access
KIP-999: Server-side Consumer Lag Metrics
KIP-1000: List Client Metrics Configuration Resources
KIP-1001: Add CurrentControllerId Metric
KIP-1002: Fetch remote segment indexes at once
KIP-1003: Signal next segment when remote fetching
KIP-1004: Enforce tasks.max property in Kafka Connect
KIP-1005: Expose EarliestLocalOffset and TieredOffset
KIP-1006: Remove SecurityManager Support
KIP-1007: Introduce Remote Storage Not Ready Exception
KIP-1009: Add Broker-level Throttle Configurations
KIP-1008: ParKa - the Marriage of Parquet and Kafka
KIP-1010: Topic Partition Quota
KIP-1011: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh
KIP-1012: The need for a Kafka 3.8.x release
KIP-1013: Drop broker and tools support for Java 11 in Kafka 4.0 (deprecate in 3.7)
KIP-1014: Managing Unstable Metadata Versions in Apache Kafka
KIP-1015: Limit number of ssl connections in brokers
KIP-1016 Make MM2 heartbeats topic name configurable
KIP-1017: Health check endpoint for Kafka Connect
KIP-1018: Introduce max remote fetch timeout config for DelayedRemoteFetch requests
KIP-1019: Expose method to determine Metric Measurability
KIP-1020: Deprecate `window.size.ms` in `StreamsConfig`
1,010 more child pages
Browse pages
Configure
Space tools
View Page
A
t
tachments (0)
Page History
Page Information
View in Hierarchy
View Source
Delete comments
Export to PDF
Export to Word
Copy Page Tree
Pages
Index
Kafka Improvement Proposals
Page Information
Title:
Kafka Improvement Proposals
Author:
Jay Kreps
Jan 15, 2015
Last Changed by:
Matthias Sax
Feb 16, 2024
Tiny Link:
(useful for email)
https://cwiki-test.apache.org/confluence/x/4QwIAw
Export As:
Word
·
PDF
Incoming Links
CASSANDRA (2)
Page:
CEP-36: A Configurable ChannelProxy to alias external storage locations
Page:
CEP-34: mTLS based client and internode authenticators
Apache Kafka (102)
Page:
KIP-749: Add --files and --file-separator options to the ConsoleProducer
Page:
KIP-950: Tiered Storage Disablement
Page:
KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores
Page:
KIP-716: Allow configuring the location of the offset-syncs topic with MirrorMaker2
Page:
KIP-861: Add BytesIn/BytesOut per listener metrics
Page:
KIP-624: Consolidate Offset Validation into Fetch Protocol
Page:
KIP-628: ConsumerPerformance's multi-thread implementation
Page:
KIP-348 Deprecate null from SourceTask#poll()
Page:
KIP-23 - Add JSON/CSV output and looping options to ConsumerGroupCommand
Page:
KIP-NEXT: Support dynamic update of delete.topic.enable config
Page:
KIP-681: Rename master key in delegation token feature
Page:
KIP-363: Allow performance tools to print final results to output file
Page:
[DISCARD] KIP-658 Deprecate all setters of Headers
Page:
KIP-946: Modify exceptions thrown by Consumer APIs
Page:
KIP-999: Server-side Consumer Lag Metrics
Page:
Release Plan 1.1.0 (2018 Feb.)
Page:
KIP-672: Introduce Kafka Streams Specific Uncaught Exception Handler
Page:
KIP-753: ACL authentication, Host field support IP network segment
Page:
KIP-1003: Signal next segment when remote fetching
Page:
KIP-451: Make TopologyTestDriver output iterable
Page:
KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation
Page:
KIP-641 An new java interface to replace 'kafka.common.MessageReader'
Page:
KIP-NEXT: Add support of quota configuration in the KafkaAdminClient
Page:
KIP-879: Multi-level Rack Awareness
Page:
KIP-851: Add requireStable flag into ListConsumerGroupOffsetsOptions
Page:
KIP-436: Add a metric indicating start time
Page:
489: Kafka Consumer Record Latency Metric
Page:
KIP-992: Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery
Page:
KIP-789: Use localhost:9092 as default bootstrap-server/broker-list in client tools
Page:
KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule
Page:
KIP-776: Add Consumer#peek for debugging/tuning
Page:
KIP-752: Support --bootstrap-server in ReplicaVerificationTool
Page:
KIP-1002: Fetch remote segment indexes at once
Page:
KIP-483: Add Broker Version API in Admin Client
Page:
KIP-250 Add Support for Quorum-based Producer Acknowledgment
Page:
KIP-964: Have visibility when produce requests become "async"
Page:
KIP-254: JsonConverter Exception Handeling
Page:
KIP-373: Allow users to create delegation tokens for other users
Page:
KIP-375: Kafka Clients - make Metadata#TOPIC_EXPIRY_MS configurable
Page:
KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde
Page:
KIP-806: Add session and window query over kv-store in IQv2
Page:
KIP-278 - Add version option to Kafka's commands
Page:
KIP-332: Update AclCommand to use AdminClient API
Page:
KIP-576: Support dynamic update of more broker configs related to replication
Page:
KIP-499 - Unify connection name flag for command line tool
Page:
KIP-668: Expose REST endpoint to list converter plugins
Page:
KIP-187 - Add cumulative count metric for all Kafka rate metrics
Page:
KIP-593: Enable --if-exists and --if-not-exists for AdminClient in TopicCommand
Page:
KIP-294 - Enable TLS hostname verification by default
Page:
KIP-420: Add Single Value Fetch in Session Stores
Page:
KIP-176: Remove deprecated new-consumer option for tools
Page:
KIP-677: migrating Topology methods to the Builder pattern (WIP)
Page:
KIP-969: Support range interactive queries (IQv2) for versioned state stores
Page:
KIP-403: Increase ProducerPerformance precision by using nanoTime
Page:
KIP-188 - Add new metrics to support health checks
Page:
KIP-330: Add retentionPeriod in SessionBytesStoreSupplier
Page:
KIP-59: Proposal for a kafka broker command
Page:
KIP-715: Expose Committed offset in streams
Page:
KIP-785: Automatic storage formatting
Page:
KIP-831: Add metric for log recovery progress
Page:
KIP-701: Add--override option to bin/connect-distributed.sh
Page:
KIP-XX: Decouple Kafka Streams Scalability from Physical partition
Home page:
Index
Page:
Contributing Code Changes
Page:
KIP-327: Add describe all topics API to AdminClient
Page:
KIP-757: Topic metadata
Page:
KIP-931: Flag to ignore unused message attribute field
Page:
KIP-997: update WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery
Page:
KIP-DRAFT: Error Handling in Connect
Page:
KIP-711 Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException
Page:
KIP-506: Allow setting SCRAM password via Admin interface
Page:
Release Plan 1.0.0 (2017 Oct.)
Page:
KIP-344: The auto-generated client id should be passed to MetricsReporter
Page:
KIP-661: Expose task configurations in Connect REST API
Page:
KIP-754: Make Scala case class's final
Page:
KIP-1005: Expose EarliestLocalOffset and TieredOffset
Page:
KIP-473: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers
Page:
KIP-371: Add a configuration to build custom SSL principal name
Page:
KIP-NEXT: Get rid of unnecessary read lock
Page:
KIP-Template
Page:
KIP-241 KTable repartition with compacted Topics
Page:
Release Plan 0.11.0.0
Page:
KIP-DRAFT: Handle errors for data inside put method of a sink connector
Page:
KIP-367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)
Page:
KIP-357: Add support to list ACLs per principal
Page:
KIP-: Broker Registration Mechanism
Page:
KIP-113: Support replicas movement between log directories
Page:
KIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig
Page:
KIP-395: Encypt-then-MAC Delegation token metadata
Page:
KIP-862: Self-join optimization for stream-stream joins
Page:
KIP-615: add ConstrainedCooperativeStickyAssignor
Page:
KIP-547: Extend ConsumerInterceptor to allow modification of Consumer Commits
Page:
KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents
Page:
KIP-246: Connect producers and consumers should inherit worker configs
Page:
KIP-338 Support to exclude the internal topics in kafka-topics.sh command
Page:
KIP-788: Allow configuring num.network.threads per listener
Page:
KIP-NEXT: Insert Title Here
Page:
KIP-583: add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker
Page:
KIP-948: Allow custom prefix for internal topic names in Kafka Streams
Page:
KIP-928: Making Kafka resilient to log directories becoming full
Page:
KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.
Page:
KIP-646 Serializer API should support ByteBuffer
Hierarchy
Parent Page
Home page:
Index
Children (1013)
Page:
drafts
Page:
KIP-1 - Remove support of request.required.acks
Page:
KIP-2 - Refactor brokers to allow listening on multiple ports and IPs
Page:
KIP-3 - Mirror Maker Enhancement
Page:
KIP-4 - Command line and centralized administrative operations
Page:
KIP-5 - Broker Configuration Management
Page:
KIP-6 - New reassignment partition logic for rebalancing
Page:
KIP-7 - Security - IP Filtering
Page:
KIP-8 - Add a flush method to the producer API
Page:
KIP-12 - Kafka Sasl/Kerberos and SSL implementation
Show all...
Page:
KIP-13 - Quotas
Page:
KIP-14 - Tools Standardization
Page:
KIP-15 - Add a close method with a timeout in the producer
Page:
KIP-16 - Automated Replica Lag Tuning
Page:
KIP-17 - Add HighwaterMarkOffset to OffsetFetchResponse
Page:
KIP-18 - JBOD Support
Page:
KIP-19 - Add a request timeout to NetworkClient
Page:
KIP-20 - Enable log preallocate to improve consume performance under windows and some old Linux file system
Page:
KIP-21 - Dynamic Configuration
Page:
KIP-22 - Expose a Partitioner interface in the new producer
Page:
KIP-23 - Add JSON/CSV output and looping options to ConsumerGroupCommand
Page:
KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request
Page:
KIP-25 - System test improvements
Page:
KIP-26 - Add Kafka Connect framework for data import/export
Page:
KIP-27 - Conditional Publish
Page:
KIP-28 - Add a processor client
Page:
KIP-29 - Add an IsrPropagateIntervalMs configuration to KafkaConfig
Page:
KIP-30 - Allow for brokers to have plug-able consensus and meta data storage sub systems
Page:
KIP-31 - Move to relative offsets in compressed message sets
Page:
KIP-32 - Add timestamps to Kafka message
Page:
KIP-33 - Add a time based log index
Page:
KIP-34 Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case
Page:
KIP-35 - Retrieving protocol version
Page:
KIP-36 Rack aware replica assignment
Page:
KIP-37 - Add Namespaces to Kafka
Page:
KIP-38: ZooKeeper Authentication
Page:
KIP-39 Pinning controller to broker
Page:
KIP-40: ListGroups and DescribeGroup
Page:
KIP-41: KafkaConsumer Max Records
Page:
KIP-42: Add Producer and Consumer Interceptors
Page:
KIP-43: Kafka SASL enhancements
Page:
KIP-44 - Allow Kafka to have a customized security protocol
Page:
KIP-45 - Standardize all client sequence interaction on j.u.Collection.
Page:
KIP-46: Self Healing Kafka
Page:
KIP-47 - Add timestamp-based log deletion policy
Page:
KIP-48 Delegation token support for Kafka
Page:
KIP-49 - Fair Partition Assignment Strategy
Page:
KIP-50 - Move Authorizer to o.a.k.common package
Page:
KIP-51 - List Connectors REST API
Page:
KIP-52: Connector Control APIs
Page:
KIP-53 - Add custom policies for reconnect attempts to NetworkdClient
Page:
KIP-54 - Sticky Partition Assignment Strategy
Page:
KIP-55: Secure Quotas for Authenticated Users
Page:
KIP-56: Allow cross origin HTTP requests on all HTTP methods
Page:
KIP-57 - Interoperable LZ4 Framing
Page:
KIP-58 - Make Log Compaction Point Configurable
Page:
KIP-59: Proposal for a kafka broker command
Page:
KIP-60 - Make Java client classloading more flexible
Page:
KIP-61: Add a log retention parameter for maximum disk space usage percentage
Page:
KIP-62: Allow consumer to send heartbeats from a background thread
Page:
KIP-63: Unify store and downstream caching in streams
Page:
KIP-64 -Allow underlying distributed filesystem to take over replication depending on configuration
Page:
KIP-65: Expose timestamps to Connect
Page:
KIP-66: Single Message Transforms for Kafka Connect
Page:
KIP-67: Queryable state for Kafka Streams
Page:
KIP-68 Add a consumed log retention before log retention
Page:
KIP-69 - Kafka Schema Registry
Page:
KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change
Page:
KIP-71: Enable log compaction and deletion to co-exist
Page:
KIP-72: Allow putting a bound on memory consumed by Incoming requests
Page:
KIP-73 Replication Quotas
Page:
KIP-74: Add Fetch Response Size Limit in Bytes
Page:
KIP-75 - Add per-connector Converters
Page:
KIP-76 Enable getting password from executable rather than passing as plaintext in config files
Page:
KIP-77: Improve Kafka Streams Join Semantics
Page:
KIP-78: Cluster Id
Page:
KIP-79 - ListOffsetRequest/ListOffsetResponse v1 and add timestamp search methods to the new consumer
Page:
KIP-80: Kafka Rest Server
Page:
KIP-81: Bound Fetch memory usage in the consumer
Page:
KIP-82 - Add Record Headers
Page:
KIP-83 - Allow multiple SASL authenticated Java clients in a single JVM process
Page:
KIP-84: Support SASL SCRAM mechanisms
Page:
KIP-85: Dynamic JAAS configuration for Kafka clients
Page:
KIP-86: Configurable SASL callback handlers
Page:
KIP-87 - Add Compaction Tombstone Flag
Page:
KIP-88: OffsetFetch Protocol Update
Page:
KIP-89: Allow sink connectors to decouple flush and offset commit
Page:
KIP-90 - Remove zkClient dependency from Streams
Page:
KIP-91 Provide Intuitive User Timeouts in The Producer
Page:
KIP-92 - Add per partition lag metrics to KafkaConsumer
Page:
KIP-93: Improve invalid timestamp handling in Kafka Streams
Page:
KIP-94 Session Windows
Page:
KIP-95: Incremental Batch Processing for Kafka Streams
Page:
KIP-96 - Add per partition metrics for in-sync and assigned replica count
Page:
KIP-97: Improved Kafka Client RPC Compatibility Policy
Page:
KIP-98 - Exactly Once Delivery and Transactional Messaging
Page:
KIP-99: Add Global Tables to Kafka Streams
Page:
KIP-100 - Relax Type constraints in Kafka Streams API
Page:
KIP-101 - Alter Replication Protocol to use Leader Epoch rather than High Watermark for Truncation
Page:
KIP-102 - Add close with timeout for consumers
Page:
KIP-103: Separation of Internal and External traffic
Page:
KIP-104: Granular Sensors for Streams
Page:
KIP-105: Addition of Recording Level for Sensors
Page:
KIP-106 - Change Default unclean.leader.election.enabled from True to False
Page:
KIP-107: Add deleteRecordsBefore() API in AdminClient
Page:
KIP-108: Create Topic Policy
Page:
KIP-109: Old Consumer Deprecation
Page:
KIP-110: Add Codec for ZStandard Compression
Page:
KIP-111: Kafka should preserve the Principal generated by the PrincipalBuilder while processing the request received on socket channel, on the broker.
Page:
KIP-112: Handle disk failure for JBOD
Page:
KIP-113: Support replicas movement between log directories
Page:
KIP-114: KTable state stores and improved semantics
Page:
KIP-115: Enforce offsets.topic.replication.factor upon __consumer_offsets auto topic creation
Page:
KIP-116: Add State Store Checkpoint Interval Configuration
Page:
KIP-117: Add a public AdminClient API for Kafka admin operations
Page:
KIP-118: Drop Support for Java 7
Page:
KIP-119: Drop Support for Scala 2.10 in Kafka 0.11
Page:
KIP-120: Cleanup Kafka Streams builder API
Page:
KIP-121: Add KStream peek method
Page:
KIP-122: Add Reset Consumer Group Offsets tooling
Page:
KIP-123: Allow per stream/table timestamp extractor
Page:
KIP-124 - Request rate quotas
Page:
KIP-Template
Page:
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback
Page:
KIP-127: Pluggable JAAS LoginModule configuration for SSL
Page:
KIP-126 - Allow KafkaProducer to split and resend oversized batches.
Page:
KIP-128: Add ByteArrayConverter for Kafka Connect
Page:
KIP-129: Streams Exactly-Once Semantics
Page:
KIP 130: Expose states of active tasks to KafkaStreams public API
Page:
KIP-131 - Add access to OffsetStorageReader from SourceConnector
Page:
KIP-132: Augment KStream.print to allow extra parameters in the printed string
Page:
KIP-133: Describe and Alter Configs Admin APIs
Page:
KIP-134: Delay initial consumer group rebalance
Page:
KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user
Page:
KIP-136: Add Listener name to SelectorMetrics tags
Page:
KIP-137: Enhance TopicCommand --describe to show topics marked for deletion
Page:
KIP-138: Change punctuate semantics
Page:
KIP-139: Kafka TestKit library
Page:
KIP-140: Add administrative RPCs for adding, deleting, and listing ACLs
Page:
KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors
Page:
KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster
Page:
KIP-148: Add a connect timeout for client
Page:
KIP-143: Controller Health Metrics
Page:
KIP-144: Exponential backoff for broker reconnect attempts
Page:
KIP-146 - Classloading Isolation in Connect
Page:
KIP-145 - Expose Record Headers in Kafka Connect
Page:
KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods
Page:
KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner
Page:
KIP-150 - Kafka-Streams Cogroup
Page:
KIP-151 Expose Connector type in REST API
Page:
KIP-152 - Improve diagnostics for SASL authentication failures
Page:
KIP-153: Include only client traffic in BytesOutPerSec metric
Page:
KIP-154 Add Kafka Connect configuration properties for creating internal topics
Page:
KIP 155 - Add range scan for windowed state stores
Page:
KIP 156 Add option "dry run" to Streams application reset tool
Page:
KIP 157 - Add consumer config options to streams reset tool
Page:
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics
Page:
KIP-159: Introducing Rich functions to Streams
Page:
KIP-160: Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string
Page:
KIP-161: streams deserialization exception handlers
Page:
KIP-162 - Enable topic deletion by default
Page:
KIP-163: Lower the Minimum Required ACL Permission of OffsetFetch
Page:
KIP-164- Add UnderMinIsrPartitionCount and per-partition UnderMinIsr metrics
Page:
KIP-165: Extend Interactive Queries for return latest update timestamp per key
Page:
KIP-166 - Add a tool to make amounts of replicas and leaders on brokers balanced
Page:
KIP-167: Add interface for the state store restoration process
Page:
KIP-168: Add GlobalTopicCount and GlobalPartitionCount metrics per cluster
Page:
KIP-169 - Lag-Aware Partition Assignment Strategy
Page:
KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicy
Page:
KIP-171 - Extend Consumer Group Reset Offset for Stream Application
Page:
KIP 172: Add regular-expression topic support for sink connector
Page:
KIP-173: Add prefix to StreamsConfig to enable setting default internal topic configs
Page:
KIP-174 - Deprecate and remove internal converter configs in WorkerConfig
Page:
KIP-175: Additional '--describe' views for ConsumerGroupCommand
Page:
KIP-176: Remove deprecated new-consumer option for tools
Page:
KIP-178: Size-based log directory selection strategy
Page:
Old KIP-179 - Change ReassignPartitionsCommand to use AdminClient
Page:
KIP-180: Add a broker metric specifying the number of consumer group rebalances in progress
Page:
KIP-181: DescribeGroups Protocol Enhancement
Page:
KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines
Page:
KIP-179 - Change ReassignPartitionsCommand to use AdminClient
Page:
KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient
Page:
KIP-184: Rename LogCleaner and related classes to LogCompactor
Page:
KIP-185: Make exactly once in order delivery per partition the default producer setting
Page:
KIP-186: Increase offsets retention default to 7 days
Page:
KIP-177: Consumer perf tool should count rebalance time
Page:
KIP-187 - Add cumulative count metric for all Kafka rate metrics
Page:
KIP-188 - Add new metrics to support health checks
Page:
KIP-189: Improve principal builder interface and add support for SASL
Page:
KIP-190: Handle client-ids consistently between clients and brokers
Page:
KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern
Page:
KIP-192 : Provide cleaner semantics when idempotence is enabled
Page:
KIP-193: Add SchemaBuilder.from(Schema)
Page:
KIP-195: AdminClient.createPartitions
Page:
KIP-196: Add metrics to Kafka Connect framework
Page:
KIP-197 Connect REST API should include the connector type when describing a connector
Page:
KIP-198: Remove ZK dependency from Streams Reset Tool
Page:
KIP-199: Add Kafka Connect offset tool
Page:
KIP-201: Rationalising Policy interfaces
Page:
KIP-202 Move merge() from StreamsBuilder to KStream
Page:
KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule
Page:
KIP-204 : Adding records deletion operation to the new Admin Client API
Page:
KIP-205: Add all() and range() API to ReadOnlyWindowStore
Page:
KIP-206: Add support for UUID serialization and deserialization
Page:
KIP-207: Offsets returned by ListOffsetsResponse should be monotonically increasing even during a partition leader change
Page:
KIP-208: Add SSL support to Kafka Connect REST interface
Page:
KIP-209 - Connection String Support
Page:
KIP-210 - Provide for custom error handling when Kafka Streams fails to produce
Page:
KIP-211: Revise Expiration Semantics of Consumer Group Offsets
Page:
KIP-212: Enforce set of legal characters for connector names
Page:
KIP-213 Support non-key joining in KTable
Page:
KIP-214: Add zookeeper.max.in.flight.requests config to the broker
Page:
KIP-215: Add topic regex support for Connect sinks
Page:
KIP-216: IQ should throw different exceptions for different errors
Page:
KIP-217: Expose a timeout to allow an expired ZK session to be re-created
Page:
KIP-218: Make KafkaFuture.Function java 8 lambda compatible
Page:
KIP-219 - Improve quota communication
Page:
KIP-220: Add AdminClient into Kafka Streams' ClientSupplier
Page:
KIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint
Page:
KIP-222 - Add Consumer Group operations to Admin API
Page:
KIP-223 - Add per-topic min lead and per-partition lead metrics to KafkaConsumer
Page:
KIP-224: Add configuration parameter `retries` to Streams API
Page:
KIP-225 - Use tags for consumer “records.lag” metrics
Page:
KIP-226 - Dynamic Broker Configuration
Page:
KIP-227: Introduce Incremental FetchRequests to Increase Partition Scalability
Page:
KIP-228 Negative record timestamp support
Page:
KIP-229: DeleteGroups API
Page:
KIP 230: Name Windowing Joins
Page:
KIP-231: Improve the Required ACL of ListGroups API
Page:
KIP-232: Detect outdated metadata using leaderEpoch and partitionEpoch
Page:
KIP-233: Simplify StreamsBuilder#addGlobalStore
Page:
KIP-234: add support for getting topic defaults from AdminClient
Page:
KIP-235: Add DNS alias support for secured connection
Page:
KIP-236: Interruptible Partition Reassignment
Page:
KIP-237: More Controller Health Metrics
Page:
KIP-238: Expose Kafka cluster ID in Connect REST API
Page:
KIP-239 Add queryableStoreName() to GlobalKTable
Page:
KIP-240: AdminClient.listReassignments AdminClient.describeReassignments
Page:
KIP-241 KTable repartition with compacted Topics
Page:
KIP-242: Mask password in Kafka Connect Rest API response
Page:
KIP-243: Make ProducerConfig and ConsumerConfig constructors public
Page:
KIP-244: Add Record Header support to Kafka Streams Processor API
Page:
KIP-245: Use Properties instead of StreamsConfig in KafkaStreams constructor
Page:
KIP-260: add primary join operation for Stream-Stream join (WIP)
Page:
KIP-246: Connect producers and consumers should inherit worker configs
Page:
KIP-247: Add public test utils for Kafka Streams
Page:
KIP-248 - Create New ConfigCommand That Uses The New AdminClient
Page:
KIP-249: Add Delegation Token Operations to KafkaAdminClient
Page:
KIP-250 Add Support for Quorum-based Producer Acknowledgment
Page:
KIP-251: Allow timestamp manipulation in Processor API
Page:
KIP-252 - Extend ACLs to allow filtering based on ip ranges and subnets
Page:
KIP-253: Support in-order message delivery with partition expansion
Page:
KIP-254: JsonConverter Exception Handeling
Page:
KIP-255 OAuth Authentication via SASL/OAUTHBEARER
Page:
KIP-256: Add RocksDB statistics via Streams metrics
Page:
KIP-257 - Configurable Quota Management
Page:
KIP-258: Allow to Store Record Timestamps in RocksDB
Page:
KIP-259: Improve Streams DSL Timestamp Propagation Semantics
Page:
KIP-261: Add Single Value Fetch in Window Stores
Page:
KIP-262: Metadata should include number of state stores for task
Page:
KIP-263: Allow broker to skip sanity check of inactive segments on broker startup
Page:
KIP-264: Add a consumer metric to record raw fetch size
Page:
KIP-265: Make Windowed Serde to public APIs
Page:
KIP-266: Fix consumer indefinite blocking behavior
Page:
KIP-267: Add Processor Unit Test Support to Kafka Streams Test Utils
Page:
KIP-268: Simplify Kafka Streams Rebalance Metadata Upgrade
Page:
KIP 269 Substitution Within Configuration Values
Page:
KIP-270 - A Scala Wrapper Library for Kafka Streams
Page:
KIP-271: Add NetworkClient redirector
Page:
KIP-272: Add API version tag to broker's RequestsPerSec metric
Page:
KIP-273 - Kafka to support using ETCD beside Zookeeper
Page:
KIP-274: Kafka Streams Skipped Records Metrics
Page:
KIP-275 - Indicate "isClosing" in the SinkTaskContext
Page:
KIP-276 Add StreamsConfig prefix for different consumers
Page:
KIP-277 - Fine Grained ACL for CreateTopics API
Page:
KIP-278 - Add version option to Kafka's commands
Page:
KIP-281: ConsumerPerformance: Increase Polling Loop Timeout and Make It Reachable by the End User
Page:
KIP-279: Fix log divergence between leader and follower after fast leader fail over
Page:
KIP-280: Enhanced log compaction
Page:
KIP-282: Add the listener name to the authentication context
Page:
KIP-283: Efficient Memory Usage for Down-Conversion
Page:
KIP-284: Set default retention ms for Streams repartition topics to Long.MAX_VALUE
Page:
KIP-285: Connect Rest Extension Plugin
Page:
KIP-286: producer.send() should not block on metadata update
Page:
KIP-287: Support partition and processor expansion for stateful processing jobs
Page:
KIP-288: [DISCARDED] Consumer.poll() timeout semantic change and new waitForAssignment method
Page:
KIP-289: Improve the default group id behavior in KafkaConsumer
Page:
KIP-290: Support for Prefixed ACLs
Page:
KIP-292: Add transformValues() method to KTable
Page:
KIP-293 Add new metrics for consumer/replication fetch requests
Page:
KIP-291: Separating controller connections and requests from the data plane
Page:
KIP-294 - Enable TLS hostname verification by default
Page:
KIP-295: Add Streams Configuration Allowing for Optional Topology Optimization
Page:
KIP-296: Connector level configurability for client configs
Page:
KIP-NEXT: Get rid of unnecessary read lock
Page:
KIP-297: Externalizing Secrets for Connect Configurations
Page:
KIP-DRAFT: Error Handling in Connect
Page:
KIP-298: Error Handling in Connect
Page:
KIP-300: Add Windowed KTable API in StreamsBuilder
Page:
KIP-301: Schema Inferencing for JsonConverter
Page:
KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses
Page:
KIP-303: Add Dynamic Routing in Streams Sink
Page:
KIP-304: Connect runtime mode improvements for container platforms
Page:
KIP-305: Add Connect primitive number converters
Page:
KIP-306: Configuration for Delaying Response to Failed Client Authentication
Page:
KIP-307: Allow to define custom processor names with KStreams DSL
Page:
KIP-635: GetOffsetShell: support for multiple topics and consumer configuration override
Page:
KIP-308: Support dynamic update of max.connections.per.ip/max.connections.per.ip.overrides configs
Page:
KIP-309: Add toUpperCase support to sasl.kerberos.principal.to.local rule
Page:
KIP-310: Add a Kafka Source Connector to Kafka Connect
Page:
KIP-311: Async processing with dynamic scheduling in Kafka Streams
Page:
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues
Page:
KIP-312: Add Overloaded StreamsBuilder Build Method to Accept java.util.Properties
Page:
KIP-314: KTable to GlobalKTable Bi-directional Join
Page:
KIP-316: Command-line overrides for ConnectDistributed worker properties
Page:
KIP-317: Add end-to-end data encryption functionality to Apache Kafka
Page:
KIP-318: Make Kafka Connect Source idempotent
Page:
KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplier
Page:
KIP-315: Stream Join Sticky Assignor
Page:
KIP-320: Allow fetchers to detect and handle log truncation
Page:
KIP-321: Update TopologyDescription to better represent Source and Sink Nodes
Page:
KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.
Page:
KIP-326: Schedulable KTable as Graph source
Page:
KIP-324: Add method to get metrics() in AdminClient
Page:
KIP-327: Add describe all topics API to AdminClient
Page:
KIP-325: Extend Consumer Group Command to Show Beginning Offsets
Page:
KIP-328: Ability to suppress updates for KTables
Page:
KIP-330: Add retentionPeriod in SessionBytesStoreSupplier
Page:
KIP-332: Update AclCommand to use AdminClient API
Page:
KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde
Page:
KIP-333: Add faster mode of rebalancing
Page:
KIP-334 - Include partitions in exceptions raised during consumer record deserialization/validation
Page:
KIP-335: Consider configurations for KafkaStreams
Page:
KIP-336: Consolidate ExtendedSerializer/Serializer and ExtendedDeserializer/Deserializer
Page:
KIP-338 Support to exclude the internal topics in kafka-topics.sh command
Page:
KIP-339: Create a new IncrementalAlterConfigs API
Page:
KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file
Page:
KIP-341: Update Sticky Assignor's User Data Protocol
Page:
KIP-342: Add support for Custom SASL extensions in OAuthBearer authentication
Page:
KIP-343: Add a Controller Heartbeat Mechanism
Page:
KIP-344: The auto-generated client id should be passed to MetricsReporter
Page:
KIP-345: Introduce static membership protocol to reduce consumer rebalances
Page:
KIP-346 - Improve LogCleaner behavior on error
Page:
KIP-347: Enable batching in FindCoordinatorRequest
Page:
KIP-348 Deprecate null from SourceTask#poll()
Page:
KIP-349: Priorities for Source Topics
Page:
KIP-350: Allow kafka-topics.sh to take brokerid as parameter to show partitions associated with it
Page:
KIP-351: Add --under-min-isr option to describe topics command
Page:
KIP-352: Distinguish URPs caused by reassignment
Page:
KIP-353: Improve Kafka Streams Timestamp Synchronization
Page:
KIP-354: Add a Maximum Log Compaction Lag
Page:
KIP-356: Add withCachingDisabled() to StoreBuilder
Page:
KIP-356: Add KafkaConsumer fetch-error-rate and fetch-error-total metrics
Page:
KIP-357: Add support to list ACLs per principal
Page:
KIP-358: Migrate Streams API to Duration instead of long ms times
Page:
KIP-359: Verify leader epoch in produce requests
Page:
KIP-360: Improve reliability of idempotent/transactional producer
Page:
KIP-361: Add Consumer Configuration to Disable Auto Topic Creation
Page:
KIP-362: Support dynamic gap session window
Page:
KIP-363: Allow performance tools to print final results to output file
Page:
KIP-366: Make FunctionConversions deprecated
Page:
KIP-364: Remove implicit Materialized, Consumed and Produced
Page:
KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde
Page:
KIP-367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)
Page:
KIP-368: Allow SASL Connections to Periodically Re-Authenticate
Page:
KIP-369: Alternative Partitioner to Support "Always Round-Robin" Selection
Page:
KIP-370: Remove Orphan Partitions
Page:
KIP-371: Add a configuration to build custom SSL principal name
Page:
KIP-354: Time-based log compaction policy
Page:
KIP-372: Naming Repartition Topics for Joins and Grouping
Page:
KIP-373: Allow users to create delegation tokens for other users
Page:
KIP-374: Add '--help' option to all available Kafka CLI commands
Page:
KIP-375: Kafka Clients - make Metadata#TOPIC_EXPIRY_MS configurable
Page:
KIP-376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement
Page:
KIP-377: TopicCommand to use AdminClient
Page:
KIP-378: Enable Dependency Injection for Kafka Streams handlers
Page:
KIP-379: Multiple Consumer Group Management
Page:
KIP-380: Detect outdated control requests and bounced brokers using broker generation
Page:
KIP-381: Connect: Tell about records that had their offsets flushed in callback
Page:
KIP-382: MirrorMaker 2.0
Page:
KIP-383: Pluggable interface for SSL Factory
Page:
KIP-384: Add config for incompatible changes to persistent metadata
Page:
KIP-385: Avoid throwing away prefetched data
Page:
KIP-386: Standardize on Min/Avg/Max metrics' default value
Page:
KIP-387: Fair Message Consumption Across Partitions in KafkaConsumer
Page:
KIP-388: Add observer interface to record request and response
Page:
KIP-389: Introduce a configurable consumer group size limit
Page:
KIP-390: Support Compression Level
Page:
KIP-391: Allow Producing with Offsets for Cluster Replication [Discarded]
Page:
KIP-392: Allow consumers to fetch from closest replica
Page:
KIP-393: Time windowed serde to properly deserialize changelog input topic
Page:
KIP-394: Require member.id for initial join group request
Page:
KIP-395: Encypt-then-MAC Delegation token metadata
Page:
KIP-396: Add Reset/List Offsets Operations to AdminClient
Page:
KIP-397: Add methods to override fetch offsets based on timestamp
Page:
KIP-398: Support reading trust store from classpath
Page:
KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions
Page:
KIP-400: Improve exit status in case of errors in ConsoleProducer
Page:
KIP-401: TransformerSupplier/ProcessorSupplier StateStore connecting
Page:
KIP-402: Improve fairness in SocketServer processors
Page:
KIP-403: Increase ProducerPerformance precision by using nanoTime
Page:
KIP-404: Add Kafka Connect configuration parameter for disabling WADL output on OPTIONS request
Page:
KIP-405: Kafka Tiered Storage
Page:
KIP-406: GlobalStreamThread should honor custom reset policy
Page:
KIP-407: Kafka Connect support override worker kafka api configuration with connector configuration that post by rest api
Page:
KIP-NEXT: Add support of quota configuration in the KafkaAdminClient
Page:
KIP-408: Add Asynchronous Processing To Kafka Streams
Page:
KIP-409: Allow creating under-replicated topics and partitions
Page:
KIP-410: Add metric for request handler thread pool utilization by request type
Page:
KIP-411: Make default Kafka Connect worker task client IDs distinct
Page:
KIP-412: Extend Admin API to support dynamic application log levels
Page:
KIP-414: Expose Embedded ClientIds in Kafka Streams
Page:
KIP-416: Notify SourceTask of ACK'd offsets, metadata
Page:
KIP-415: Incremental Cooperative Rebalancing in Kafka Connect
Page:
KIP-417: Allow JmxTool to connect to a secured RMI port
Page:
KIP-418: A method-chaining way to branch KStream
Page:
KIP-419: Safely notify Kafka Connect SourceTask is stopped
Page:
KIP-420: Add Single Value Fetch in Session Stores
Page:
KIP-706: Add method "Producer#send" to return CompletionStage instead of Future
Page:
KIP-531: Drop support for Scala 2.11 in Kafka 2.5
Page:
KIP-421: Automatically resolve external configurations.
Page:
KIP-422: Add support for client quota configuration in the Kafka Admin Client
Page:
KIP-423: Add JoinReason to Consumer Join Group Protocol
Page:
KIP-424: Allow suppression of intermediate events based on wall clock time
Page:
KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers
Page:
KIP-426: Persist Broker Id to Zookeeper
Page:
KIP-427: Add AtMinIsr topic partition category (new metric & TopicCommand option)
Page:
KIP-428: Add in-memory window store
Page:
KIP-429: Kafka Consumer Incremental Rebalance Protocol
Page:
KIP-430 - Return Authorized Operations in Describe Responses
Page:
KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter
Page:
KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation
Page:
KIP-433: Block old clients on brokers
Page:
KIP-434: Add Replica Fetcher and Log Cleaner Count Metrics
Page:
KIP-435: Internal Partition Reassignment Batching
Page:
KIP-436: Add a metric indicating start time
Page:
KIP-437: Custom replacement for MaskField SMT
Page:
KIP-438: Expose task, connector IDs in Connect API
Page:
KIP-439: Cleanup built-in Store interfaces
Page:
KIP-440: Extend Connect Converter to support headers
Page:
KIP-441: Smooth Scaling Out for Kafka Streams
Page:
KIP-446: Add changelog topic configuration to KTable suppress
Page:
KIP-442: Return to default max poll interval in Streams
Page:
KIP-443: Return to default segment.ms and segment.index.bytes in Streams repartition topics
Page:
KIP-444: Augment metrics for Kafka Streams
Page:
KIP-445: In-memory Session Store
Page:
KIP-447: Producer scalability for exactly once semantics
Page:
KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils
Page:
KIP-449: Add connector contexts to Connect worker logs
Page:
KIP-450: Sliding Window Aggregations in the DSL
Page:
KIP-451: Make TopologyTestDriver output iterable
Page:
KIP-452: Tool to view cluster status
Page:
KIP-454: Expansion of the ConnectClusterState interface
Page:
KIP-455: Create an Administrative API for Replica Reassignment
Page:
KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver
Page:
KIP-457: Add DISCONNECTED status to Kafka Streams
Page:
KIP-458: Connector Client Config Override Policy
Page:
KIP-459: Improve KafkaStreams#close
Page:
KIP-460: Admin Leader Election RPC
Page:
KIP-462: Use local thread id for KStreams
Page:
KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder
Page:
KIP-461 - Improve Replica Fetcher behavior at handling partition failure
Page:
KIP-464: Defaults for AdminClient#createTopic
Page:
KIP-465: Add Consolidated Connector Endpoint to Connect REST API
Page:
KIP-453: Add close() method to RocksDBConfigSetter
Page:
KIP-466: Add support for List<T> serialization and deserialization
Page:
KIP-467: Augment ProduceResponse error messaging for specific culprit records
Page:
KIP-468: Avoid decompression of record when validate record at server in the scene of inPlaceAssignment .
Page:
KIP-469: Pre-registration support for static members
Page:
KIP-470: TopologyTestDriver test input and output usability improvements
Page:
KIP-471: Expose RocksDB Metrics in Kafka Streams
Page:
KIP-472: [STREAMS] Add partition time field to RecordContext
Page:
KIP-473: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers
Page:
KIP-474: To deprecate WindowStore#put(key, value)
Page:
KIP-475: New Metrics to Measure Number of Tasks on a Connector
Page:
KIP-476: Add Java AdminClient Interface
Page:
KIP-477: Add PATCH method for connector config in Connect REST API
Page:
KIP-478 - Strongly typed Processor API
Page:
KIP-479: Add StreamJoined config object to Join
Page:
KIP-480: Sticky Partitioner
Page:
KIP-481: SerDe Improvements for Connect Decimal type in JSON
Page:
KIP-483: Add Broker Version API in Admin Client
Page:
KIP-484: Expose metrics for group and transaction metadata loading duration
Page:
KIP-497: Add inter-broker API to alter ISR
Page:
KIP-482: The Kafka Protocol should Support Optional Tagged Fields
Page:
KIP-485: Make topic optional when using through() operations in DSL
Page:
KIP-486: Support custom way to load KeyStore and TrustStore
Page:
KIP-487: Client-side Automatic Topic Creation on Producer
Page:
KIP-488: Clean up Sum,Count,Total Metrics
Page:
489: Kafka Consumer Record Latency Metric
Page:
KIP-490: New metric to count offsets expired without being consumed by a consumer group
Page:
KIP-491: Preferred Leader Deprioritized List (Temporary Blacklist)
Page:
KIP-492: Add java security providers in Kafka Security config
Page:
KIP-494: Connect REST Endpoint to get Transformations (SMTs)
Page:
KIP-495: Dynamically Adjust Log Levels in Connect
Page:
KIP-496: Administrative API to delete consumer offsets
Page:
KIP-498: Add client-side configuration for maximum response size to protect against OOM
Page:
KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum
Page:
KIP-501 Avoid out-of-sync or offline partitions when follower fetch requests are not processed in time
Page:
KIP-499 - Unify connection name flag for command line tool
Page:
KIP-502: Connect Task Method Signature to be More Specific for Developers
Page:
KIP-503: Add metric for number of topics marked for deletion
Page:
KIP-504 - Add new Java Authorizer Interface
Page:
KIP-505: Add new public method to only update assignment metadata in consumer
Page:
KIP-506: Allow setting SCRAM password via Admin interface
Page:
KIP-507: Securing Internal Connect REST Endpoints
Page:
KIP-508: Make Suppression State Queriable
Page:
KIP-509: Rebalance and restart Producers
Page:
KIP-510: Metrics library upgrade
Page:
KIP-511: Collect and Expose Client's Name and Version in the Brokers
Page:
KIP-512:Adding headers to RecordMetaData
Page:
KIP-513: Distinguish between Key and Value serdes in scala wrapper library for kafka streams
Page:
KIP-532: Broker Consumer Lag metrics in size and time
Page:
KIP-514: Add a bounded flush() API to Kafka Producer
Page:
KIP-515: Enable ZK client to use the new TLS supported authentication
Page:
KIP-534: Retain tombstones and transaction markers for approximately delete.retention.ms milliseconds
Page:
KIP-516: Topic Identifiers
Page:
KIP-517: Add consumer metrics to observe user poll behavior
Page:
KIP-518: Allow listing consumer groups per state
Page:
KIP-519: Make SSL context/engine configuration extensible
Page:
KIP-520: Add overloaded Consumer#committed for batching partitions
Page:
KIP-521: Enable redirection of Connect's log4j messages to a file by default
Page:
KIP-522: Update BrokerApiVersionsCommand to use AdminClient
Page:
KIP-523: Add KStream#toTable to the Streams DSL
Page:
KIP-524: Allow users to choose config source when describing configs
Page:
KIP-525 - Return topic metadata and configs in CreateTopics response
Page:
KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics
Page:
KIP-527: Add VoidSerde to Serdes
Page:
KIP-528: Deprecate PartitionGrouper configuration and interface
Page:
KIP-530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'
Page:
KIP-533: Add default api timeout to AdminClient
Page:
KIP-X: Introduce a cooperative consumer processing semantic
Page:
KIP-535: Allow state stores to serve stale reads during rebalance
Page:
KIP-536: Propagate broker start time to Admin API
Page:
KIP-537: Increase default zookeeper session timeout
Page:
KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type
Page:
KIP-539: Implement mechanism to flush out records in low traffic suppression buffers
Page:
KIP-540: Implement per key stream time tracking
Page:
KIP-541: Create a fetch.max.bytes configuration for the broker
Page:
KIP-542: Partition Reassignment Throttling
Page:
KIP-543: Expand ConfigCommand's non-ZK functionality
Page:
KIP-545: support automated consumer offset sync across clusters in MM 2.0
Page:
KIP-XX: Decouple Kafka Streams Scalability from Physical partition
Page:
KIP-544: Make metrics exposed via JMX configurable
Page:
KIP-546: Add Client Quota APIs to the Admin Client
Page:
KIP-547: Extend ConsumerInterceptor to allow modification of Consumer Commits
Page:
KIP-548 Add Option to enforce rack-aware custom partition reassignment execution
Page:
KIP-549: Surface Consumer's Metadata in KafkaAdminClient#describeConsumerGroups
Page:
KIP-565: Using AclCommand,avoid call the global method loadcache in SimpleAclAuthorizer
Page:
KIP-550: Mechanism to Delete Stray Partitions on Broker
Page:
KIP-551: Expose disk read and write metrics
Page:
KIP-553: Disable all SSL protocols except TLSV1.2 by default.
Page:
KIP-555: Deprecate Direct Zookeeper access in Kafka Administrative Tools
Page:
KIP-557: Add emit on change support for Kafka Streams
Page:
KIP-558: Track the set of actively used topics by connectors in Kafka Connect
Page:
KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies
Page:
KIP-560: Auto infer external topic partitions in stream reset tool
Page:
KIP-561: Regex Support for ConsumerGroupCommand
Page:
KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance
Page:
KIP-564: Add new cached authorizer:change the dim of cache
Page:
KIP-563: Add 'tail -n' feature for ConsoleConsumer
Page:
KIP-566: Add rebalance callbacks to ConsumerInterceptor
Page:
KIP-567: Kafka Cluster Audit
Page:
KIP-568: Support RPC message type 'double'
Page:
KIP-DRAFT: Handle errors for data inside put method of a sink connector
Page:
KIP-568: Explicit rebalance triggering on the Consumer
Page:
KIP-569: DescribeConfigsResponse - Update the schema to include additional metadata information of the field
Page:
KIP-570: Add leader epoch in StopReplicaRequest
Page:
KIP-571: Add option to force remove members in StreamsResetter
Page:
KIP-572: Improve timeouts and retries in Kafka Streams
Page:
KIP-573: Enable TLSv1.3 by default
Page:
KIP-574: CLI Dynamic Configuration with file input
Page:
KIP-575: build a Kafka-Exporter by Java
Page:
KIP-576: Support dynamic update of more broker configs related to replication
Page:
KIP 577: Allow HTTP Response Headers to be Configured for Kafka Connect
Page:
KIP-578: Add configuration to limit number of partitions
Page:
KIP-579: new exception on min.insync.replicas > replication.factor
Page:
KIP-580: Exponential Backoff for Kafka Clients
Page:
KIP-581: Value of optional null field which has default value
Page:
KIP-582: Add a "continue" option for Kafka Connect error handling
Page:
KIP-583: add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker
Page:
KIP-584: Versioning scheme for features
Page:
KIP-585: Filter and Conditional SMTs
Page:
KIP-586: Deprecate commit records without record metadata
Page:
KIP-587: Suppress detailed responses for handled exceptions in security-sensitive environments
Page:
KIP-588: Allow producers to recover gracefully from transaction timeouts
Page:
KIP-590: Redirect Zookeeper Mutation Protocols to The Controller
Page:
KIP-589 Add API to update Replica state in Controller
Page:
KIP-591: Add Kafka Streams config to set default state store
Page:
KIP-592: MirrorMaker 1.0 should replicate topics from earliest
Page:
KIP-593: Enable --if-exists and --if-not-exists for AdminClient in TopicCommand
Page:
KIP-596: Safely abort Producer transactions during application shutdown
Page:
KIP-594: Expose output topic names from TopologyTestDriver
Page:
KIP-595: A Raft Protocol for the Metadata Quorum
Page:
KIP-597: MirrorMaker2 internal topics Formatters
Page:
KIP-598: Augment TopologyDescription with store and source / sink serde information
Page:
KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations
Page:
KIP-601: Configurable socket connection timeout in NetworkClient
Page:
KIP-602: Change default value for client.dns.lookup
Page:
KIP-603: Change `ConfigEntry` value to use optional fields
Page:
KIP-605: Expand Connect Worker Internal Topic Settings
Page:
KIP-554: Add Broker-side SCRAM Config API
Page:
KIP-604: Remove ZooKeeper Flags from the Administrative Tools
Page:
KIP-606: Add Metadata Context to MetricsReporter
Page:
KIP-608 - Expose Kafka Metrics in Authorizer
Page:
KIP-609: Use Pre-registration and Blocking Calls for Better Transaction Efficiency
Page:
KIP-607: Add Metrics to Kafka Streams to Report Properties of RocksDB
Page:
KIP-610: Error Reporting in Sink Connectors
Page:
KIP-611: Improved Handling of Abandoned Connectors and Tasks
Page:
KIP-612: Ability to Limit Connection Creation Rate on Brokers
Page:
KIP-614: Add Prefix Scan support for State Stores
Page:
KIP-613: Add end-to-end latency metrics to Streams
Page:
KIP-615: add ConstrainedCooperativeStickyAssignor
Page:
KIP-616: Rename implicit Serdes instances in kafka-streams-scala
Page:
KIP-617: Allow Kafka Streams State Stores to be iterated backwards
Page:
KIP-618: Exactly-Once Support for Source Connectors
Page:
KIP-620 Deprecate ConsumerConfig#addDeserializerToConfig and ProducerConfig#addSerializerToConfig
Page:
KIP-619: Add internal topic creation support
Page:
KIP-621: Deprecate and replace DescribeLogDirsResult.all() and .values()
Page:
KIP-622: Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext
Page:
KIP-623: Add "internal-topics" option to streams application reset tool
Page:
KIP-624: Consolidate Offset Validation into Fetch Protocol
Page:
KIP-625: Richer encodings for integral-typed protocol fields
Page:
KIP-626: Rename StreamsConfig config variable name
Page:
KIP-627: Expose Trogdor-specific JMX Metrics for Tasks and Agents
Page:
KIP-628: ConsumerPerformance's multi-thread implementation
Page:
KIP-629: Use racially neutral terms in our codebase
Page:
KIP-630: Kafka Raft Snapshot
Page:
KIP-631: The Quorum-based Kafka Controller
Page:
KIP-634: Complementary support for headers and record metadata in Kafka Streams DSL
Page:
KIP-636: Make RPC error codes and messages tagged fields
Page:
KIP-637: Include min.insync.replicas in MetadataResponse to make Producer smarter in partitioning events
Page:
KIP-638: Deprecate DescribeLogDirsResponse.[LogDirInfo, ReplicaInfo]
Page:
KIP-639: Move nodeLevelSensor and storeLevelSensor methods from StreamsMetricsImpl to StreamsMetrics
Page:
KIP-640: Add log compression analysis tool
Page:
KIP-641 An new java interface to replace 'kafka.common.MessageReader'
Page:
KIP-642: Dynamic quorum reassignment
Page:
KIP-644: Support sources which can't give out changed data in kafka connect
Page:
KIP-645: Replace Windows with a proper interface
Page:
KIP-646 Serializer API should support ByteBuffer
Page:
KIP-647: Add ability to handle late messages in streams-aggregation
Page:
KIP-648: Renaming getter method for Interactive Queries
Page:
KIP-649: Dynamic Client Configuration
Page:
KIP-650: Enhance Kafkaesque Raft semantics
Page:
KIP-656: MirrorMaker2 Exactly-once Semantics
Page:
KIP-651 - Support PEM format for SSL certificates and private key
Page:
KIP-653: Upgrade log4j to log4j2
Page:
KIP-654: Aborted transaction with non-flushed data should throw a non-fatal exception
Page:
KIP-632: Add DirectoryConfigProvider
Page:
KIP-655: Windowed Distinct Operation for Kafka Streams API
Page:
KIP-657: Add Customized Kafka Streams Logo
Page:
[DISCARD] KIP-658 Deprecate all setters of Headers
Page:
KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size
Page:
KIP-660: Pluggable ReplicaPlacer
Page:
KIP-661: Expose task configurations in Connect REST API
Page:
KIP-662: Throw Exception when Source Topics of a Streams App are Deleted
Page:
KIP-663: API to Start and Shut Down Stream Threads
Page:
KIP-664: Provide tooling to detect and abort hanging transactions
Page:
KIP-665: Kafka Connect Hash SMT
Page:
KIP-666: Add Instant-based methods to ReadOnlySessionStore
Page:
KIP-667: Remove deprecated methods from ReadOnlyWindowStore
Page:
KIP-668: Expose REST endpoint to list converter plugins
Page:
KIP-669: Preserve Source Partition in Kafka Streams from context
Page:
KIP-670: Add ConsumerGroupCommand to delete static members
Page:
KIP-671: Introduce Kafka Streams Specific Uncaught Exception Handler
Page:
KIP-672: Introduce Kafka Streams Specific Uncaught Exception Handler
Page:
KIP-673: Emit JSONs with new auto-generated schema
Page:
KIP-674: Metric Reporter to Aggregate Metrics in Kafka Streams
Page:
KIP-675: Convert KTable to a KStream using the previous value
Page:
KIP-676: Respect logging hierarchy
Page:
KIP-677: migrating Topology methods to the Builder pattern (WIP)
Page:
KIP-679: Producer will enable the strongest delivery guarantee by default
Page:
KIP-678: New Kafka Connect SMT for plainText => Struct(or Map) with Regex
Page:
KIP-680: TopologyTestDriver should not require a Properties argument
Page:
KIP-681: Rename master key in delegation token feature
Page:
KIP-682: Connect TimestampConverter support for multiple fields and multiple input formats
Page:
KIP-683: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSON string
Page:
KIP-684 - Support mutual TLS authentication on SASL_SSL listeners
Page:
KIP-685: Loosen permission for listing reassignments
Page:
KIP-686: API to ensure Records policy on the broker
Page:
KIP-695: Further Improve Kafka Streams Timestamp Synchronization
Page:
KIP-691: Enhance Transactional Producer Exception Handling
Page:
KIP-687: Automatic Reloading of Security Store
Page:
KIP-NEXT: Support dynamic update of delete.topic.enable config
Page:
KIP-688: Support dynamic update of delete.topic.enable config
Page:
KIP-698: Add Explicit User Initialization of Broker-side State to Kafka Streams
Page:
KIP-689: Extend `StreamJoined` to allow more store configs
Page:
KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention
Page:
KIP-xxx: Cache the UpdateMetadata requests in controller
Page:
KIP-694: Support Reducing Partitions for Topics
Page:
KIP-692: Make AdminClient value object constructors public
Page:
KIP-693: Client-side Circuit Breaker for Partition Write Errors
Page:
KIP-X: Native TopK support in Kafka Streams
Page:
KIP-696: Update Streams FSM to clarify ERROR state meaning
Page:
KIP-697: Stricter parsing of addresses in configs
Page:
KIP-699: Update FindCoordinator to resolve multiple Coordinators at a time
Page:
KIP-700: Add Describe Cluster API
Page:
KIP-701: Add--override option to bin/connect-distributed.sh
Page:
KIP-702: The control plane needs to force the validation of requests from the controller
Page:
KIP-703: Add a metrics for reporting idle connections closed
Page:
KIP-704: Send a hint to the partition leader to recover the partition
Page:
KIP-705: Selectively Disable Topology Optimizations
Page:
KIP-707: The future of KafkaFuture
Page:
KIP-708: Rack aware StandbyTask assignment for Kafka Streams
Page:
KIP-709: Extend OffsetFetch requests to accept multiple group ids.
Page:
KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters
Page:
KIP-711 Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException
Page:
KIP-712: Shallow Mirroring
Page:
KIP-713: Validation of Enums in configuration
Page:
KIP-714: Client metrics and observability
Page:
KIP-715: Expose Committed offset in streams
Page:
KIP-716: Allow configuring the location of the offset-syncs topic with MirrorMaker2
Page:
KIP-717: Deprecate batch-size config from console producer
Page:
KIP-718: Make KTable Join on Foreign key unopinionated
Page:
KIP-719: Deprecate Log4J Appender
Page:
KIP-720: Deprecate MirrorMaker v1
Page:
KIP-721: Enable connector log contexts in Connect Log4j configuration
Page:
KIP-722: Enable connector client overrides by default
Page:
KIP-723: Add socket.tcp.no.delay property to Kafka Config
Page:
KIP-724: Drop support for message formats v0 and v1
Page:
KIP-725: Streamlining configurations for WindowedSerializer and WindowedDeserializer.
Page:
KIP-726: Make the "cooperative-sticky, range" as the default assignor
Page:
KIP-727: Add --under-preferred-replica-partitions option to describe topics command
Page:
KIP-633: Deprecate 24-hour Default Grace Period for Windowed Operations in Streams
Page:
KIP-728: Introduce the RESTORING state to the KafkaStreams state machine
Page:
KIP-729: Custom validation of records on the broker prior to log append
Page:
KIP-730: Producer ID generation in KRaft mode
Page:
KIP-731: Record Rate Limiting for Kafka Connect
Page:
KIP-732: Deprecate eos-alpha and replace eos-beta with eos-v2
Page:
KIP-733: change Kafka Streams default replication factor config
Page:
KIP-734: Improve AdminClient.listOffsets to return timestamp and offset for the record with the largest timestamp
Page:
KIP-735: Increase default consumer session timeout
Page:
KIP-736: Report the true end to end fetch latency
Page:
KIP-738: Removal of Connect's internal converter properties
Page:
KIP-737: Add canTrackSource to ReplicationPolicy
Page:
KIP-739: Block Less on KafkaProducer#send
Page:
KIP-740: Clean up public API in TaskId
Page:
KIP-741: Change default serde to be null
Page:
KIP-743: Remove config value 0.10.0-2.4 of Streams built-in metrics version config
Page:
KIP-744: Migrate TaskMetadata and ThreadMetadata to an interface with internal implementation
Page:
KIP-751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0)
Page:
KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)
Page:
KIP-746: Revise KRaft Metadata Records
Page:
KIP-745: Connect API to restart connector and tasks
Page:
KIP-748: Add Broker Count Metrics
Page:
KIP-749: Add --files and --file-separator options to the ConsoleProducer
Page:
KIP-752: Support --bootstrap-server in ReplicaVerificationTool
Page:
KIP-753: ACL authentication, Host field support IP network segment
Page:
KIP-754: Make Scala case class's final
Page:
KIP-755: Add new AUTO_CREATE ACL for auto topic creation
Page:
KIP-756: Move StreamsResetter tool outside of core
Page:
KIP-757: Topic metadata
Page:
KIP-758: Remove list of latest producer append information for broker
Page:
KIP-759: Unneeded repartition canceling
Page:
KIP-760: Minimum value for segment.ms and segment.bytes
Page:
KIP-761: Add Total Blocked Time Metric to Streams
Page:
KIP-762: Delete Committed Connect Records
Page:
KIP-763: Range queries with open endpoints
Page:
KIP-764: Configurable backlog size for creating Acceptor
Page:
KIP-765: Introduce new SlidingWindow type for [start,end] time
Page:
KIP-766: fetch/findSessions queries with open endpoints for SessionStore/WindowStore
Page:
KIP-767: Connect Latency Metrics
Page:
KIP-768: Extend SASL/OAUTHBEARER with Support for OIDC
Page:
KIP-769: Connect APIs to list all connector plugins and retrieve their configuration definitions
Page:
KIP-770: Replace "buffered.records.per.partition" & "cache.max.bytes.buffering" with "{statestore.cache}/{input.buffer}.max.bytes"
Page:
KIP-772: Encrypt KRaft Metadata Secrets at Rest
Page:
KIP-773: Differentiate consistently metric latency measured in millis and nanos
Page:
KIP-774: Deprecate public access to Admin client's *Result constructors
Page:
KIP-775: Custom partitioners in foreign key joins
Page:
KIP-776: Add Consumer#peek for debugging/tuning
Page:
KIP-777: Improved testability for Admin client
Page:
KIP-778: KRaft to KRaft Upgrades
Page:
KIP-779: Allow Source Tasks to Handle Producer Exceptions
Page:
KIP-780: Support fine-grained compression options
Page:
KIP-781: Improve MirrorMaker2's client configuration
Page:
KIP-782: Expandable batch size in producer
Page:
KIP-783: Add TaskId field to StreamsException
Page:
KIP-784: Add top-level error code field to DescribeLogDirsResponse
Page:
KIP-785: Automatic storage formatting
Page:
KIP-786: Emit Metric Client Quota Values
Page:
KIP-789: Use localhost:9092 as default bootstrap-server/broker-list in client tools
Page:
KIP-787: MM2 manage Kafka resources with custom Admin implementation.
Page:
KIP-788: Allow configuring num.network.threads per listener
Page:
KIP-796: Interactive Query v2
Page:
KIP-791: Add Record Metadata to State Store Context
Page:
KIP-792: Add "generation" field into consumer protocol
Page:
KIP-793: Allow sink connectors to be used with topic-mutating SMTs
Page:
KIP-794: Strictly Uniform Sticky Partitioner
Page:
KIP-795: Add public APIs for AbstractCoordinator
Page:
KIP-797: Accept duplicate listener on port for IPv4/IPv6
Page:
KIP-798: Add possibility to write kafka headers in Kafka Console Producer
Page:
KIP-799: Align behaviour for producer callbacks with documented behaviour
Page:
KIP-800: Add reason to JoinGroupRequest and LeaveGroupRequest
Page:
KIP-801: Implement an Authorizer that stores metadata in __cluster_metadata
Page:
KIP-802: Validation Support for Kafka Connect SMT and Converter Options
Page:
KIP-803: Add Task ID and Connector Name to Connect Task Context
Page:
KIP-804: OfflinePartitionsCount Tagged by Topic
Page:
KIP-805: Add range and scan query over kv-store in IQv2
Page:
KIP-806: Add session and window query over kv-store in IQv2
Page:
KIP-807: Refactor KafkaStreams exposed metadata hierarchy
Page:
KIP-808: Add support for different unix precisions in TimestampConverter SMT
Page:
KIP-809: Support live upgrades with dynamic addition/removal of modular topologies
Page:
KIP-810: Allow producing records with null values in Kafka Console Producer
Page:
KIP-NEXT: Add lowest acknowledged offset to BrokerHeartbeatResponse
Page:
KIP-811: Add config repartition.purge.interval.ms to Kafka Streams
Page:
KIP-812: Introduce another form of the `KafkaStreams.close()` API that forces the member to leave the consumer group
Page:
KIP-815: Support max-timestamp in GetOffsetShell
Page:
KIP-813: Shareable State Stores
Page:
KIP-814: Static membership protocol should let the leader skip assignment
Page:
KIP-816: Topology changes without local state reset
Page:
KIP-817: Fix inconsistency in dynamic application log levels
Page:
KIP-818: Introduce cache-size-bytes-total Task Level Metric
Page:
KIP-819: Merge multiple KStreams in one operation
Page:
KIP-820: Extend KStream process with new Processor API
Page:
KIP-821: Connect Transforms support for nested structures
Page:
KIP-822: Optimize the semantics of KafkaConsumer#pause to be consistent between the two RebalanceProtocols
Page:
KIP-823: Update Admin::describeConfigs to allow fetching specific configurations
Page:
KIP-824: Allowing dumping segmentlogs limiting the batches in the output
Page:
KIP-825: introduce a new API to control when aggregated results are produced
Page:
KIP-826: Define platforms supported
Page:
KIP-827: Expose log dirs total and usable space via Kafka API
Page:
KIP-828: Add the corresponding validator to the configuration where the validator is missing
Page:
KIP-829: (console-consumer) add print.topic property
Page:
KIP-830: Allow disabling JMX Reporter
Page:
KIP-831: Add metric for log recovery progress
Page:
KIP-832: Allow creating a producer/consumer using a producer/consumer config
Page:
KIP-833: Mark KRaft as Production Ready
Page:
KIP-834: Pause / Resume KafkaStreams Topologies
Page:
KIP-835: Monitor KRaft Controller Quorum Health
Page:
KIP-837: Allow MultiCasting a Result Record.
Page:
KIP-836: Expose replication information of the cluster metadata
Page:
[DRAFT] KIP-821: Connect Transforms support for nested structures (JsonPath-based draft)
Page:
KIP-841: Fenced replicas should not be allowed to join the ISR in KRaft
Page:
KIP-839: Provide builders for KafkaProducer/KafkaConsumer and KafkaStreams
Page:
KIP-840: Config file option for MessageReader/MessageFormatter in ConsoleProducer/ConsoleConsumer
Page:
KIP-842: Add richer group offset reset mechanisms
Page:
KIP-843: Adding addMetricIfAbsent method to Metrics
Page:
KIP-844: Transactional State Stores
Page:
KIP-845: 'HasField' predicate for kafka connect
Page:
KIP-846: Source/sink node metrics for Consumed/Produced throughput in Streams
Page:
KIP-848: The Next Generation of the Consumer Rebalance Protocol
Page:
KIP-847: Add ProducerIdCount metrics
Page:
KIP-849: Expose logdirs total and usable space via kafka-log-dirs.sh
Page:
KIP-850: REST API for filtering Connector plugins by type
Page:
KIP-851: Add requireStable flag into ListConsumerGroupOffsetsOptions
Page:
KIP-852: Optimize calculation of size for log in remote tier
Page:
KIP-853: KRaft Controller Membership Changes
Page:
KIP-854 Separate configuration for producer ID expiry
Page:
KIP-855: Add schema.namespace parameter to SetSchemaMetadata SMT in Kafka Connect
Page:
KIP-857: Streaming recursion in Kafka Streams
Page:
KIP-856: KRaft Disk Failure Recovery
Page:
KIP-858: Handle JBOD broker disk failure in KRaft
Page:
KIP-NEXT: Insert Title Here
Page:
KIP-859: Add Metadata Log Processing Error Related Metrics
Page:
KIP-860: Add client-provided option to guard against replication factor change during partition reassignments
Page:
KIP-862: Self-join optimization for stream-stream joins
Page:
KIP-861: Add BytesIn/BytesOut per listener metrics
Page:
KIP-863: Reduce CompletedFetch#parseRecord() memory copy
Page:
KIP-864: Add End-To-End Latency Metrics to Connectors
Page:
KIP-865: Support --bootstrap-server in kafka-streams-application-reset
Page:
KIP-868 Metadata Transactions
Page:
KIP-866 ZooKeeper to KRaft Migration
Page:
KIP-869: Improve Streams State Restoration Visibility
Page:
KIP-870: Retention policy based on record event time
Page:
KIP-871: Fix ByteBufferSerializer#serialize(String, ByteBuffer) compatible problem
Page:
KIP-872: Add Serializer#serializeToByteBuffer() to reduce memory copying
Page:
KIP-873: ExceptionHandlingDeserializer, RetryDeserializer, PipeSerializer, PipeDeserializer
Page:
KIP-874: TopicRoundRobinAssignor
Page:
KIP-875: First-class offsets support in Kafka Connect
Page:
KIP-877: Mechanism for plugins and connectors to register metrics
Page:
KIP-876: Time based cluster metadata snapshots
Page:
KIP-878: Internal Topic Autoscaling for Kafka Streams
Page:
KIP-879: Multi-level Rack Awareness
Page:
KIP-880: X509 SAN based SPIFFE URI ACL within mTLS Client Certificates
Page:
KIP-881: Rack-aware Partition Assignment for Kafka Consumers
Page:
KIP-882: Kafka Connect REST API configuration validation timeout improvements
Page:
KIP-883: Add isDeleted flag when stopping a connector
Page:
KIP-884: Add config to configure KafkaClientSupplier in Kafka Streams
Page:
KIP-885: Expose Broker's Name and Version to Clients
Page:
KIP-886: Add Client Producer and Consumer Builders
Page:
KIP-887: Add ConfigProvider to make use of environment variables
Page:
KIP-888: Batch describe ACLs and describe client quotas
Page:
KIP-889: Versioned State Stores
Page:
KIP-890: Transactions Server-Side Defense
Page:
KIP-891: Running multiple versions of a connector
Page:
KIP-892: Transactional Semantics for StateStores
Page:
KIP-893: The Kafka protocol should support nullable structs
Page:
KIP-894: Use incrementalAlterConfigs API for syncing topic configurations
Page:
KIP-896: Remove old client protocol API versions in Kafka 4.0
Page:
KIP-895: Dynamically refresh partition count of __consumer_offsets
Page:
KIP-897: Publish a single kafka (aka core) Maven artifact in Apache Kafka 4.0
Page:
KIP-898: Modernize Connect plugin discovery
Page:
KIP-899: Allow producer and consumer clients to rebootstrap
Page:
KIP-900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers
Page:
KIP-901: Add connectorDeleted flag when stopping tasks
Page:
KIP-902: Upgrade Zookeeper to 3.8.2
Page:
KIP-903: Replicas with stale broker epoch should not be allowed to join the ISR
Page:
KIP-904: Kafka Streams - Guarantee subtractor is called before adder if key has not changed
Page:
KIP-905: Broker interceptors
Page:
KIP-906: Tools migration guidelines
Page:
KIP-907: Add Boolean Serde to public interface
Page:
KIP-908: Add description field to connector configuration
Page:
KIP-909: DNS Resolution Failure Should Not Fail the Clients
Page:
KIP-911: Add source tag to MirrorSourceConnector metrics
Page:
KIP-912: Support decreasing send's max block time without worrying about metadata's fetch
Page:
KIP-913: add new method to provide possibility for accelerate first record's sending
Page:
KIP-914: DSL Processor Semantics for Versioned Stores
Page:
KIP-915: Txn and Group Coordinator Downgrade Foundation
Page:
KIP-910: Update Source offsets for Source Connectors without producing records
Page:
KIP-916: MM2 distributed mode flow log context
Page:
KIP-917: Additional custom metadata for remote log segment
Page:
KIP-918: MM2 Topic And Group Listener
Page:
KIP-919: Allow AdminClient to Talk Directly with the KRaft Controller Quorum and add Controller Registration
Page:
KIP-920: Support upgrading KRaft MetadataVersion based on a static config
Page:
KIP-921: OpenJDK CRaC support
Page:
KIP-922: Add the traffic metric of the partition dimension
Page:
KIP-923: Add A Grace Period to Stream Table Join
Page:
KIP-925: Rack aware task assignment in Kafka Streams
Page:
KIP-926: introducing acks=min.insync.replicas config
Page:
KIP-927: Improve the kafka-metadata-quorum output
Page:
KIP-928: Making Kafka resilient to log directories becoming full
Page:
KIP-929 : Observer Replicas
Page:
KIP-930: Rename ambiguous Tiered Storage Metrics
Page:
KIP-931: Flag to ignore unused message attribute field
Page:
KIP-932: Queues for Kafka
Page:
KIP-934: Add DeleteTopicPolicy
Page:
KIP-935: Extend AlterConfigPolicy with existing configurations
Page:
KIP-933: Publish metrics when source connector fails to poll data
Page:
KIP-936: Throttle number of active PIDs
Page:
KIP-937: Improve Message Timestamp Validation
Page:
KIP-938: Add more metrics for measuring KRaft performance
Page:
KIP-939: Support Participation in 2PC
Page:
KIP-940: Broker extension point for validating record contents at produce time
Page:
KIP-941: Range queries to accept null lower and upper bounds
Page:
KIP-942: Add Power(ppc64le) support
Page:
KIP-944: Support async runtimes in consumer
Page:
KIP-943: Add independent “offset.storage.segment.bytes” for connect-distributed.properties
Page:
KIP-945: Update threading model for Consumer
Page:
KIP-946: Modify exceptions thrown by Consumer APIs
Page:
KIP-947: Add support for consumer group protocol in Consumer
Page:
KIP-948: Allow custom prefix for internal topic names in Kafka Streams
Page:
KIP-949: Add flag to enable the usage of topic separator in MM2 DefaultReplicationPolicy
Page:
KIP-950: Tiered Storage Disablement
Page:
KIP-951: Leader discovery optimisations for the client
Page:
KIP-952: Regenerate segment-aligned producer snapshots when upgrading to a Kafka version supporting Tiered Storage
Page:
KIP-953: partition method to be overloaded to accept headers as well.
Page:
KIP-954: expand default DSL store configuration to custom types
Page:
KIP-924: customizable task assignment for Streams
Page:
KIP-955: Add stream-table join on foreign key
Page:
KIP-956 Tiered Storage Quotas
Page:
KIP-957: Support Async runtimes
Page:
KIP-958: Tiered Storage Metrics
Page:
KIP-959: Add BooleanConverter to Kafka Connect
Page:
KIP-960: Support single-key_single-timestamp interactive queries (IQv2) for versioned state stores
Page:
KIP-962: Relax non-null key requirement in Kafka Streams
Page:
KIP-963: Additional metrics in Tiered Storage
Page:
KIP-964: Have visibility when produce requests become "async"
Page:
KIP-965: Support disaster recovery between clusters by MirrorMaker
Page:
KIP-966: Eligible Leader Replicas
Page:
KIP-967: Support custom SSL configuration for Kafka Connect RestServer
Page:
KIP-969: Support range interactive queries (IQv2) for versioned state stores
Page:
KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores
Page:
KIP-970: Deprecate and remove Connect's redundant task configurations endpoint
Page:
KIP-971: Expose replication-record-lag MirrorMaker2 metric
Page:
KIP-972: Add the metric of the current running version of kafka
Page:
KIP-973: Expose per topic replication rate metrics
Page:
KIP-974: Docker Image for GraalVM based Native Kafka Broker
Page:
KIP-975: Docker Image for Apache Kafka
Page:
KIP-976: Cluster-wide dynamic log adjustment for Kafka Connect
Page:
KIP-977: Partition-Level Throughput Metrics
Page:
KIP-978: Allow dynamic reloading of certificates with different DN / SANs
Page:
KIP-979: Allow independently stop KRaft processes
Page:
KIP-980: Allow creating connectors in a stopped state
Page:
KIP-982: Access SslPrincipalMapper and kerberosShortNamer in Custom KafkaPrincipalBuilder
Page:
KIP-981: Manage Connect topics with custom implementation of Admin
Page:
KIP-983: Full speed async processing during rebalance
Page:
KIP-984: Add pluggable compression interface to Kafka
Page:
KIP-985: Add reverseRange and reverseAll query over kv-store in IQv2
Page:
KIP-986: Cross-Cluster Replication
Page:
KIP-988: Streams Standby Update Listener
Page:
KIP-989: RocksDB Iterator Metrics
Page:
KIP-995: Allow users to specify initial offsets while creating connectors
Page:
KIP-987: Connect Static Assignments
Page:
KIP-990: Capability to PAUSE Tasks on DeserializationException
Page:
KIP-996: Pre-Vote
Page:
KIP-991: Allow DropHeaders SMT to drop headers by wildcard/regexp
Page:
KIP-992: Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery
Page:
KIP-994: Minor Enhancements to ListTransactions and DescribeTransactions APIs
Page:
KIP-993: Allow restricting files accessed by File and Directory ConfigProviders
Page:
KIP-997: update WindowRangeQuery and unify WindowKeyQuery and WindowRangeQuery
Page:
KIP-998: Give ProducerConfig(props, doLog) constructor protected access
Page:
KIP-999: Server-side Consumer Lag Metrics
Page:
KIP-1000: List Client Metrics Configuration Resources
Page:
KIP-1001: Add CurrentControllerId Metric
Page:
KIP-1002: Fetch remote segment indexes at once
Page:
KIP-1003: Signal next segment when remote fetching
Page:
KIP-1004: Enforce tasks.max property in Kafka Connect
Page:
KIP-1005: Expose EarliestLocalOffset and TieredOffset
Page:
KIP-1006: Remove SecurityManager Support
Page:
KIP-1007: Introduce Remote Storage Not Ready Exception
Page:
KIP-1009: Add Broker-level Throttle Configurations
Page:
KIP-1008: ParKa - the Marriage of Parquet and Kafka
Page:
KIP-1010: Topic Partition Quota
Page:
KIP-1011: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh
Page:
KIP-1012: The need for a Kafka 3.8.x release
Page:
KIP-1013: Drop broker and tools support for Java 11 in Kafka 4.0 (deprecate in 3.7)
Page:
KIP-1014: Managing Unstable Metadata Versions in Apache Kafka
Page:
KIP-1015: Limit number of ssl connections in brokers
Page:
KIP-1016 Make MM2 heartbeats topic name configurable
Page:
KIP-1017: Health check endpoint for Kafka Connect
Page:
KIP-1018: Introduce max remote fetch timeout config for DelayedRemoteFetch requests
Page:
KIP-1019: Expose method to determine Metric Measurability
Page:
KIP-1020: Deprecate `window.size.ms` in `StreamsConfig`
Hide...
Labels
There are no labels assigned to this page.
Recent Changes
Time
Editor
Feb 16, 2024 02:08
Matthias Sax
View Changes
Feb 15, 2024 22:20
Zhifeng Chen
View Changes
Feb 15, 2024 20:56
Zhifeng Chen
View Changes
Feb 14, 2024 14:47
Apoorv Mittal
View Changes
Feb 13, 2024 17:30
Mickael Maison
View Page History
Outgoing Links
External Links (466)
https://cwiki.apache.org/confluence/display/KAFKA/KIP-568%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-616%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-941%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-480%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-342%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-443%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-510%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-823%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-999
https://cwiki.apache.org/confluence/display/KAFKA/KIP-979%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-742%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-906%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-689%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-548+A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-378%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-784%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://youtu.be/_QWogr9OngE
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-613%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-363%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-89%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-381%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-627%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-359%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-226+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-215%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP+130%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-914%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-727%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-988%3…
https://cwiki.apache.org/confluence/x/KZvkCw
https://youtu.be/6v9iBPij3wg
https://www.youtube.com/watch?v=rFW0-zJqg5I&feature=youtu.b…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-734%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-909%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-108%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-195%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-628%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-276+A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-969%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-129%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-974%3…
https://www.youtube.com/watch?v=mwBVJKtNrZU&feature=youtu.b…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-174+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-249%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-124+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-46%3A…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-224%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-406%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-635%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-3+-+M…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-769%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-189%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-973%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-196%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-72%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-84%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-994%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-957%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-763%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-544%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-424%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-122%3…
https://youtu.be/7b8t26H_qAE
https://cwiki.apache.org/confluence/display/KAFKA/KIP-539%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-748%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-19+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-54+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-103%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-171+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-222+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-138%3…
kafka.apache.org/contact
https://cwiki.apache.org/confluence/display/KAFKA/KIP-723%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-393%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-982%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-798%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-612%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-180%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-94+Se…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-980%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-922%3…
https://cwiki.apache.org/confluence/x/PxU0Dw
https://cwiki.apache.org/confluence/display/KAFKA/KIP-436%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-391%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-197+C…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-827%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-86%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-977%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-426%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1015%…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-693%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-344%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-729%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-159%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-121%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-640%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-522%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-205%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-243%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-659%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-190%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-188+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-501+A…
https://youtu.be/GcG91l7FQ3c
https://cwiki.apache.org/confluence/display/KAFKA/KIP-41%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-80%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-883%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-21+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-220%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-140%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-137%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-236%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-+22+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-905%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-56%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-62%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-153%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-98+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-889%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-176%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-310%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-648%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-411%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-579%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-509%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-917%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-187+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-167%3…
https://issues.apache.org/jira/browse/KAFKA-4180
https://cwiki.apache.org/confluence/display/KAFKA/KIP-245%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-48+De…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-660%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-371%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-672%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-966%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-88%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-940%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-921%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-191%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-351%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-212%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-151+E…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-361%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-209+-…
https://lists.apache.org/thread.html/r54ac94ce2ad7c055e1fce…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-357%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-101+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-911%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-959%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-534%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-561%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-499+-…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-161%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-109%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-679%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-25+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-346+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-875%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-830%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-661%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-327%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-240%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-421%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP+269+S…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-67%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-408%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-97%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-186%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-950%3…
https://youtu.be/ZdUEu5v3-Cw
https://cwiki.apache.org/confluence/display/KAFKA/KIP-57+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-119%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-732%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-461+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-877%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-233%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-379%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-995%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-106+-…
https://youtu.be/fxd9MlLdd_c
https://cwiki.apache.org/confluence/display/KAFKA/KIP-43%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-229%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-791%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-916%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-102+-…
https://youtu.be/WIoiQBi_lsE
https://cwiki.apache.org/confluence/display/KAFKA/KIP-93%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-69+-+…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-912%3…
https://lists.apache.org/thread/hsymgx73gmpm1mxhysroxx7f2lh…
https://issues.apache.org/jira/browse/KAFKA-4090
https://cwiki.apache.org/confluence/display/KAFKA/KIP-178%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-908%3…
https://selfserve.apache.org/jira-account.html
https://cwiki.apache.org/confluence/display/KAFKA/KIP-73+Re…
https://issues.apache.org/jira/browse/KAFKA-10136
https://cwiki.apache.org/confluence/display/KAFKA/KIP-31+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-20+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-694%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-718%3…
https://cwiki.apache.org/confluence/pages/resumedraft.actio…
https://www.youtube.com/watch?v=fr55FooRXpI
https://cwiki.apache.org/confluence/display/KAFKA/KIP-759%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-273+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-492%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-15+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-578%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-203%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP+678%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP+157+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-716%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-35+-+…
https://github.com/apache/kafka/pull/99
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1018%…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-380%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-149%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-341%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-112%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-206%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-75+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-120%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-698%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-74%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-279%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-514%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-681%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-113%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-179+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-268%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-737%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-223+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-11+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-227%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-50+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-289%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-375%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-232%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-944%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-33+-+…
https://youtu.be/UcUcT0wYlzY
https://cwiki.apache.org/confluence/display/KAFKA/KIP-890%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-91+Pr…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-16+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-997%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-918%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-238%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-182%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-615%3…
https://www.mail-archive.com/dev@kafka.apache.org/msg100621…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-799%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-704%3…
https://cwiki.apache.org/confluence/signup.action
https://cwiki.apache.org/confluence/display/KAFKA/KIP-850%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-466%3…
https://youtu.be/APlWPNxiq7A
https://cwiki.apache.org/confluence/display/KAFKA/KIP-2+-+R…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-152+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-862%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-472%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-202+M…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-210+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-949%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-78%3A…
https://github.com/apache/kafka/pull/130
https://cwiki.apache.org/confluence/display/KAFKA/KIP-676%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-201%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-354%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-164-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-291%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-118%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-40%3A…
https://youtu.be/Hcjur17TjBE
https://cwiki.apache.org/confluence/display/KAFKA/KIP-105%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-960%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-114%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-208%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-387%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-913%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-237%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-177%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-903%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-14+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-668%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-204+%…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-154+A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-702%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-96+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-802%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-445%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-183+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-136%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-207%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-853%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-265%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-65%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-965%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-773%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-168%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-894%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-410%3…
https://lists.apache.org/thread/ftlnolcrh858dry89sjg06mdcdj…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-58+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-838+S…
https://youtu.be/AyG_rUowEis
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-4+-+C…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-134%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-810%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1019%…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-115%3…
https://youtu.be/RyyTCVCl9BA
https://cwiki.apache.org/confluence/display/KAFKA/KIP-774%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-71%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-192+%…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-8+-+A…
https://cwiki.apache.org/confluence/x/DB1RCg
https://cwiki.apache.org/confluence/display/KAFKA/KIP-162+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-283%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-736%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1007%…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-85%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-267%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-347%3…
https://issues.apache.org/jira/browse/KAFKA-3663
https://cwiki.apache.org/confluence/display/KAFKA/KIP-66%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-937%3…
https://www.mail-archive.com/dev@kafka.apache.org/msg102178…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-257+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-290%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-42%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-165%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-214%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-143%3…
https://www.youtube.com/watch?v=ko34LJEr4wA
https://cwiki.apache.org/confluence/display/KAFKA/KIP-272%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-77%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-453%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-513%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-364%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-266%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-373%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-100+-…
https://cwiki.apache.org/confluence/display/KAFKA/489%3A+Ka…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-63%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-703%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1+-+R…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-338+S…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
mailto:dev@kafka.apache.org
https://cwiki.apache.org/confluence/display/KAFKA/KIP-377%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-239+A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-274%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-251%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-81%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-888%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-602%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-32+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-90+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-795%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-146+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-350%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-801%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-901%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-145+-…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-284%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-699%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-150+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-985%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-1008%…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-311%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-13+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-173%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-144%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-28+-+…
https://www.youtube.com/watch?v=1ZMjimctFCs&feature=youtu.b…
https://cwiki.apache.org/confluence/display/KAFKA/Bylaws#By…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-52%3A…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-133%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-854+S…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-160%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-219+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-743%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-593%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-826%3…
https://cwiki.apache.org/confluence/x/aRRRCg
https://youtu.be/GN-i9Vq-J5k
https://cwiki.apache.org/confluence/display/KAFKA/KIP+155+-…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-132+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-563%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-198%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-107%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-29+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-59%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-362%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-368%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-281%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-51+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-261%3…
https://cwiki.apache.org/confluence/pages/resumedraft.actio…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-175%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-674%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-131+-…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-247%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-104%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-70%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-783%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP+577%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-295%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-36+Ra…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-450%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-60+-+…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-312%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-675%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-557%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-253%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-55%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-211%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-793%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-899%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-38%3A…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-970%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-185%3…
cwiki.apache.org/confluence/display/KAFKA/KIP-487%3A+Client…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-128%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-688%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-320%3…
https://youtu.be/MCnS8OB2-v4
https://cwiki.apache.org/confluence/display/KAFKA/KIP-560%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-117%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-662%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-696%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-218%3…
https://cwiki.apache.org/confluence/display/KAFKA/KIP-512%3…
https://cwiki.apache.org/confluence/pages/viewpage.action?p…
Apache Kafka (517)
Page:
KIP-942: Add Power(ppc64le) support
Page:
KIP-216: IQ should throw different exceptions for different errors
Page:
KIP-955: Add stream-table join on foreign key
Page:
KIP-473: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers
Page:
KIP-972: Add the metric of the current running version of kafka
Page:
KIP-933: Publish metrics when source connector fails to poll data
Page:
KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils
Page:
KIP-671: Introduce Kafka Streams Specific Uncaught Exception Handler
Page:
KIP-409: Allow creating under-replicated topics and partitions
Page:
KIP-786: Emit Metric Client Quota Values
Page:
KIP-439: Cleanup built-in Store interfaces
Page:
KIP-407: Kafka Connect support override worker kafka api configuration with connector configuration that post by rest api
Page:
KIP-788: Allow configuring num.network.threads per listener
Page:
KIP-667: Remove deprecated methods from ReadOnlyWindowStore
Page:
KIP-711 Deprecate org.apache.kafka.streams.errors.BrokerNotFoundException
Page:
KIP-530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'
Page:
KIP-800: Add reason to JoinGroupRequest and LeaveGroupRequest
Page:
KIP-947: Add support for consumer group protocol in Consumer
Page:
KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter
Page:
KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster
Page:
KIP-1016 Make MM2 heartbeats topic name configurable
Page:
KIP-882: Kafka Connect REST API configuration validation timeout improvements
Page:
KIP-390: Support Compression Level
Page:
KIP-653: Upgrade log4j to log4j2
Page:
KIP-720: Deprecate MirrorMaker v1
Page:
KIP-895: Dynamically refresh partition count of __consumer_offsets
Page:
KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors
Page:
KIP-930: Rename ambiguous Tiered Storage Metrics
Page:
KIP-836: Expose replication information of the cluster metadata
Page:
KIP-366: Make FunctionConversions deprecated
Page:
KIP-975: Docker Image for Apache Kafka
Page:
KIP-885: Expose Broker's Name and Version to Clients
Page:
KIP-847: Add ProducerIdCount metrics
Page:
KIP-936: Throttle number of active PIDs
Page:
KIP-887: Add ConfigProvider to make use of environment variables
Page:
KIP-515: Enable ZK client to use the new TLS supported authentication
Page:
KIP-595: A Raft Protocol for the Metadata Quorum
Page:
KIP-898: Modernize Connect plugin discovery
Page:
KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request
Page:
KIP-481: SerDe Improvements for Connect Decimal type in JSON
Page:
KIP-923: Add A Grace Period to Stream Table Join
Page:
KIP-775: Custom partitioners in foreign key joins
Page:
KIP-857: Streaming recursion in Kafka Streams
Page:
KIP-385: Avoid throwing away prefetched data
Page:
KIP-87 - Add Compaction Tombstone Flag
Page:
KIP-746: Revise KRaft Metadata Records
Page:
KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde
Page:
KIP-6 - New reassignment partition logic for rebalancing
Page:
KIP-928: Making Kafka resilient to log directories becoming full
Page:
KIP-497: Add inter-broker API to alter ISR
Page:
KIP-169 - Lag-Aware Partition Assignment Strategy
Page:
KIP-984: Add pluggable compression interface to Kafka
Page:
KIP-280: Enhanced log compaction
Page:
KIP-931: Flag to ignore unused message attribute field
Page:
KIP-527: Add VoidSerde to Serdes
Page:
KIP-110: Add Codec for ZStandard Compression
Page:
KIP-926: introducing acks=min.insync.replicas config
Page:
KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics
Page:
KIP-300: Add Windowed KTable API in StreamsBuilder
Page:
KIP-95: Incremental Batch Processing for Kafka Streams
Page:
KIP-843: Adding addMetricIfAbsent method to Metrics
Page:
KIP-726: Make the "cooperative-sticky, range" as the default assignor
Page:
KIP-567: Kafka Cluster Audit
Page:
KIP-543: Expand ConfigCommand's non-ZK functionality
Page:
KIP-649: Dynamic Client Configuration
Page:
KIP-740: Clean up public API in TaskId
Page:
KIP-277 - Fine Grained ACL for CreateTopics API
Page:
KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers
Page:
KIP-160: Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string
Page:
KIP-987: Connect Static Assignments
Page:
KIP-892: Transactional Semantics for StateStores
Page:
KIP-533: Add default api timeout to AdminClient
Page:
KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicy
Page:
KIP-804: OfflinePartitionsCount Tagged by Topic
Page:
KIP-608 - Expose Kafka Metrics in Authorizer
Page:
KIP-507: Securing Internal Connect REST Endpoints
Page:
KIP-856: KRaft Disk Failure Recovery
Page:
KIP-761: Add Total Blocked Time Metric to Streams
Page:
KIP-938: Add more metrics for measuring KRaft performance
Page:
KIP-968: Support single-key_multi-timestamp interactive queries (IQv2) for versioned state stores
Page:
KIP-562: Allow fetching a key from a single partition rather than iterating over all the stores on an instance
Page:
KIP 172: Add regular-expression topic support for sink connector
Page:
KIP-636: Make RPC error codes and messages tagged fields
Page:
KIP-828: Add the corresponding validator to the configuration where the validator is missing
Page:
KIP-891: Running multiple versions of a connector
Page:
KIP-508: Make Suppression State Queriable
Page:
KIP-321: Update TopologyDescription to better represent Source and Sink Nodes
Page:
KIP-708: Rack aware StandbyTask assignment for Kafka Streams
Page:
KIP-470: TopologyTestDriver test input and output usability improvements
Page:
KIP-829: (console-consumer) add print.topic property
Page:
KIP-418: A method-chaining way to branch KStream
Page:
KIP-467: Augment ProduceResponse error messaging for specific culprit records
Page:
KIP-264: Add a consumer metric to record raw fetch size
Page:
KIP-574: CLI Dynamic Configuration with file input
Page:
KIP-656: MirrorMaker2 Exactly-once Semantics
Page:
KIP-1004: Enforce tasks.max property in Kafka Connect
Page:
KIP-315: Stream Join Sticky Assignor
Page:
KIP-969: Support range interactive queries (IQv2) for versioned state stores
Page:
KIP-1000: List Client Metrics Configuration Resources
Page:
KIP-591: Add Kafka Streams config to set default state store
Page:
KIP-437: Custom replacement for MaskField SMT
Page:
KIP-37 - Add Namespaces to Kafka
Page:
KIP-762: Delete Committed Connect Records
Page:
KIP-954: expand default DSL store configuration to custom types
Page:
KIP-166 - Add a tool to make amounts of replicas and leaders on brokers balanced
Page:
KIP-719: Deprecate Log4J Appender
Page:
KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplier
Page:
KIP-805: Add range and scan query over kv-store in IQv2
Page:
KIP-10 - Running Producer, Consumers and Brokers on Mesos
Page:
KIP-398: Support reading trust store from classpath
Page:
KIP-506: Allow setting SCRAM password via Admin interface
Page:
KIP-416: Notify SourceTask of ACK'd offsets, metadata
Page:
KIP-1011: Use incrementalAlterConfigs when updating broker configs by kafka-configs.sh
Page:
KIP-83 - Allow multiple SASL authenticated Java clients in a single JVM process
Page:
KIP-482: The Kafka Protocol should Support Optional Tagged Fields
Page:
KIP-485: Make topic optional when using through() operations in DSL
Page:
KIP-590: Redirect Zookeeper Mutation Protocols to The Controller
Page:
KIP-412: Extend Admin API to support dynamic application log levels
Page:
KIP-339: Create a new IncrementalAlterConfigs API
Page:
KIP-585: Filter and Conditional SMTs
Page:
KIP-824: Allowing dumping segmentlogs limiting the batches in the output
Page:
KIP-707: The future of KafkaFuture
Page:
KIP-945: Update threading model for Consumer
Page:
KIP-886: Add Client Producer and Consumer Builders
Page:
KIP-528: Deprecate PartitionGrouper configuration and interface
Page:
KIP-855: Add schema.namespace parameter to SetSchemaMetadata SMT in Kafka Connect
Page:
KIP-266: Fix consumer indefinite blocking behavior
Page:
KIP-907: Add Boolean Serde to public interface
Page:
KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type
Page:
KIP-712: Shallow Mirroring
Page:
KIP-415: Incremental Cooperative Rebalancing in Kafka Connect
Page:
KIP-476: Add Java AdminClient Interface
Page:
KIP-566: Add rebalance callbacks to ConsumerInterceptor
Page:
KIP-927: Improve the kafka-metadata-quorum output
Page:
KIP-550: Mechanism to Delete Stray Partitions on Broker
Page:
KIP-633: Deprecate 24-hour Default Grace Period for Windowed Operations in Streams
Page:
KIP-873: ExceptionHandlingDeserializer, RetryDeserializer, PipeSerializer, PipeDeserializer
Page:
KIP-884: Add config to configure KafkaClientSupplier in Kafka Streams
Page:
KIP-516: Topic Identifiers
Page:
KIP-722: Enable connector client overrides by default
Page:
KIP-163: Lower the Minimum Required ACL Permission of OffsetFetch
Page:
KIP-292: Add transformValues() method to KTable
Page:
KIP-64 -Allow underlying distributed filesystem to take over replication depending on configuration
Page:
KIP-231: Improve the Required ACL of ListGroups API
Page:
KIP-504 - Add new Java Authorizer Interface
Page:
KIP-417: Allow JmxTool to connect to a secured RMI port
Page:
KIP-858: Handle JBOD broker disk failure in KRaft
Page:
KIP-352: Distinguish URPs caused by reassignment
Page:
KIP-845: 'HasField' predicate for kafka connect
Page:
KIP-818: Introduce cache-size-bytes-total Task Level Metric
Page:
KIP-587: Suppress detailed responses for handled exceptions in security-sensitive environments
Page:
KIP-956 Tiered Storage Quotas
Page:
KIP-394: Require member.id for initial join group request
Page:
KIP-819: Merge multiple KStreams in one operation
Page:
KIP-452: Tool to view cluster status
Page:
KIP-971: Expose replication-record-lag MirrorMaker2 metric
Page:
KIP-841: Fenced replicas should not be allowed to join the ISR in KRaft
Page:
KIP-925: Rack aware task assignment in Kafka Streams
Page:
KIP-326: Schedulable KTable as Graph source
Page:
KIP-479: Add StreamJoined config object to Join
Page:
KIP-572: Improve timeouts and retries in Kafka Streams
Page:
KIP-837: Allow MultiCasting a Result Record.
Page:
KIP-831: Add metric for log recovery progress
Page:
KIP-477: Add PATCH method for connector config in Connect REST API
Page:
KIP-541: Create a fetch.max.bytes configuration for the broker
Page:
KIP-935: Extend AlterConfigPolicy with existing configurations
Page:
KIP-294 - Enable TLS hostname verification by default
Page:
KIP-754: Make Scala case class's final
Page:
KIP-906: Tools migration guidelines
Page:
KIP-976: Cluster-wide dynamic log adjustment for Kafka Connect
Page:
KIP 230: Name Windowing Joins
Page:
KIP-569: DescribeConfigsResponse - Update the schema to include additional metadata information of the field
Page:
KIP-505: Add new public method to only update assignment metadata in consumer
Page:
KIP-870: Retention policy based on record event time
Page:
KIP-465: Add Consolidated Connector Endpoint to Connect REST API
Page:
KIP-1017: Health check endpoint for Kafka Connect
Page:
KIP-449: Add connector contexts to Connect worker logs
Page:
KIP-495: Dynamically Adjust Log Levels in Connect
Page:
KIP-686: API to ensure Records policy on the broker
Page:
KIP-637: Include min.insync.replicas in MetadataResponse to make Producer smarter in partitioning events
Page:
KIP-545: support automated consumer offset sync across clusters in MM 2.0
Page:
KIP-304: Connect runtime mode improvements for container platforms
Page:
KIP-213 Support non-key joining in KTable
Page:
KIP-370: Remove Orphan Partitions
Page:
KIP-442: Return to default max poll interval in Streams
Page:
KIP-356: Add withCachingDisabled() to StoreBuilder
Page:
KIP-583: add tag "partition" to BrokerTopicMetrics so as to observe the partition metrics on the same broker
Page:
KIP-842: Add richer group offset reset mechanisms
Page:
KIP-462: Use local thread id for KStreams
Page:
KIP-552: Suppress "unused config" warning
Page:
Old KIP-179 - Change ReassignPartitionsCommand to use AdminClient
Page:
KIP-596: Safely abort Producer transactions during application shutdown
Page:
KIP-825: introduce a new API to control when aggregated results are produced
Page:
KIP-807: Refactor KafkaStreams exposed metadata hierarchy
Page:
KIP-498: Add client-side configuration for maximum response size to protect against OOM
Page:
KIP-851: Add requireStable flag into ListConsumerGroupOffsetsOptions
Page:
KIP-49 - Fair Partition Assignment Strategy
Page:
KIP-750: Drop support for Java 8 in Kafka 4.0 (deprecate in 3.0)
Page:
KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder
Page:
KIP-314: KTable to GlobalKTable Bi-directional Join
Page:
KIP-896: Remove old client protocol API versions in Kafka 4.0
Page:
KIP-815: Support max-timestamp in GetOffsetShell
Page:
KIP-565: Using AclCommand,avoid call the global method loadcache in SimpleAclAuthorizer
Page:
KIP-234: add support for getting topic defaults from AdminClient
Page:
KIP-866 ZooKeeper to KRaft Migration
Page:
KIP-369: Alternative Partitioner to Support "Always Round-Robin" Selection
Page:
KIP-39 Pinning controller to broker
Page:
KIP-751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0)
Page:
KIP-932: Queues for Kafka
Page:
KIP-744: Migrate TaskMetadata and ThreadMetadata to an interface with internal implementation
Page:
KIP-517: Add consumer metrics to observe user poll behavior
Page:
KIP-611: Improved Handling of Abandoned Connectors and Tasks
Page:
KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics
Page:
KIP-622: Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext
Page:
KIP-532: Broker Consumer Lag metrics in size and time
Page:
KIP-262: Metadata should include number of state stores for task
Page:
KIP-665: Kafka Connect Hash SMT
Page:
KIP-897: Publish a single kafka (aka core) Maven artifact in Apache Kafka 4.0
Page:
KIP-388: Add observer interface to record request and response
Page:
KIP-880: X509 SAN based SPIFFE URI ACL within mTLS Client Certificates
Page:
KIP-382: MirrorMaker 2.0
Page:
KIP-7 - Security - IP Filtering
Page:
KIP-537: Increase default zookeeper session timeout
Page:
KIP-384: Add config for incompatible changes to persistent metadata
Page:
KIP-9 - SSL Support
Page:
KIP-803: Add Task ID and Connector Name to Connect Task Context
Page:
KIP-1001: Add CurrentControllerId Metric
Page:
KIP-900: KRaft kafka-storage.sh API additions to support SCRAM for Kafka Brokers
Page:
KIP-781: Improve MirrorMaker2's client configuration
Page:
KIP-76 Enable getting password from executable rather than passing as plaintext in config files
Page:
KIP-235: Add DNS alias support for secured connection
Page:
KIP-478 - Strongly typed Processor API
Page:
KIP-833: Mark KRaft as Production Ready
Page:
[DISCARD] KIP-658 Deprecate all setters of Headers
Page:
KIP-764: Configurable backlog size for creating Acceptor
Page:
KIP-518: Allow listing consumer groups per state
Page:
KIP-844: Transactional State Stores
Page:
KIP-934: Add DeleteTopicPolicy
Page:
KIP-869: Improve Streams State Restoration Visibility
Page:
KIP-551: Expose disk read and write metrics
Page:
KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback
Page:
KIP-690: Add additional configuration to control MirrorMaker 2 internal topics naming convention
Page:
KIP-285: Connect Rest Extension Plugin
Page:
KIP-260: add primary join operation for Stream-Stream join (WIP)
Page:
KIP-404: Add Kafka Connect configuration parameter for disabling WADL output on OPTIONS request
Page:
KIP-778: KRaft to KRaft Upgrades
Page:
KIP-576: Support dynamic update of more broker configs related to replication
Page:
KIP-785: Automatic storage formatting
Page:
KIP-792: Add "generation" field into consumer protocol
Page:
KIP-428: Add in-memory window store
Page:
KIP-735: Increase default consumer session timeout
Page:
KIP-874: TopicRoundRobinAssignor
Page:
KIP-724: Drop support for message formats v0 and v1
Page:
KIP-816: Topology changes without local state reset
Page:
KIP-625: Richer encodings for integral-typed protocol fields
Page:
KIP-721: Enable connector log contexts in Connect Log4j configuration
Page:
KIP-282: Add the listener name to the authentication context
Page:
KIP-893: The Kafka protocol should support nullable structs
Page:
KIP-328: Ability to suppress updates for KTables
Page:
KIP-1009: Add Broker-level Throttle Configurations
Page:
KIP-974: Docker Image for GraalVM based Native Kafka Broker
Page:
KIP-756: Move StreamsResetter tool outside of core
Page:
KIP-666: Add Instant-based methods to ReadOnlySessionStore
Page:
KIP-564: Add new cached authorizer:change the dim of cache
Page:
KIP-910: Update Source offsets for Source Connectors without producing records
Page:
KIP-349: Priorities for Source Topics
Page:
KIP-405: Kafka Tiered Storage
Page:
KIP-228 Negative record timestamp support
Page:
KIP-254: JsonConverter Exception Handeling
Page:
KIP-755: Add new AUTO_CREATE ACL for auto topic creation
Page:
KIP-44 - Allow Kafka to have a customized security protocol
Page:
KIP-558: Track the set of actively used topics by connectors in Kafka Connect
Page:
KIP-626: Rename StreamsConfig config variable name
Page:
KIP-306: Configuration for Delaying Response to Failed Client Authentication
Page:
KIP-17 - Add HighwaterMarkOffset to OffsetFetchResponse
Page:
KIP-990: Capability to PAUSE Tasks on DeserializationException
Page:
KIP-632: Add DirectoryConfigProvider
Page:
KIP-709: Extend OffsetFetch requests to accept multiple group ids.
Page:
KIP-525 - Return topic metadata and configs in CreateTopics response
Page:
KIP-536: Propagate broker start time to Admin API
Page:
KIP-860: Add client-provided option to guard against replication factor change during partition reassignments
Page:
KIP-438: Expose task, connector IDs in Connect API
Page:
KIP-599: Throttle Create Topic, Create Partition and Delete Topic Operations
Page:
KIP-434: Add Replica Fetcher and Log Cleaner Count Metrics
Page:
KIP-455: Create an Administrative API for Replica Reassignment
Page:
KIP-813: Shareable State Stores
Page:
KIP-258: Allow to Store Record Timestamps in RocksDB
Page:
KIP-981: Manage Connect topics with custom implementation of Admin
Page:
KIP-486: Support custom way to load KeyStore and TrustStore
Page:
KIP-582: Add a "continue" option for Kafka Connect error handling
Page:
KIP-275 - Indicate "isClosing" in the SinkTaskContext
Page:
KIP-669: Preserve Source Partition in Kafka Streams from context
Page:
KIP-994: Minor Enhancements to ListTransactions and DescribeTransactions APIs
Page:
KIP-685: Loosen permission for listing reassignments
Page:
KIP-270 - A Scala Wrapper Library for Kafka Streams
Page:
KIP-902: Upgrade Zookeeper to 3.8.2
Page:
KIP-475: New Metrics to Measure Number of Tasks on a Connector
Page:
KIP-713: Validation of Enums in configuration
Page:
KIP-641 An new java interface to replace 'kafka.common.MessageReader'
Page:
KIP-333: Add faster mode of rebalancing
Page:
KIP-811: Add config repartition.purge.interval.ms to Kafka Streams
Page:
KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions
Page:
KIP-447: Producer scalability for exactly once semantics
Page:
KIP-554: Add Broker-side SCRAM Config API
Page:
KIP-1006: Remove SecurityManager Support
Page:
KIP-782: Expandable batch size in producer
Page:
KIP-879: Multi-level Rack Awareness
Page:
KIP-302 - Enable Kafka clients to use all DNS resolved IP addresses
Page:
KIP-376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement
Page:
KIP-511: Collect and Expose Client's Name and Version in the Brokers
Page:
KIP-252 - Extend ACLs to allow filtering based on ip ranges and subnets
Page:
KIP-731: Record Rate Limiting for Kafka Connect
Page:
KIP-358: Migrate Streams API to Duration instead of long ms times
Page:
KIP-542: Partition Reassignment Throttling
Page:
KIP-440: Extend Connect Converter to support headers
Page:
KIP-989: RocksDB Iterator Metrics
Page:
KIP-201: Rationalising Policy interfaces
Page:
KIP-760: Minimum value for segment.ms and segment.bytes
Page:
KIP-502: Connect Task Method Signature to be More Specific for Developers
Page:
KIP-733: change Kafka Streams default replication factor config
Page:
KIP-651 - Support PEM format for SSL certificates and private key
Page:
KIP-588: Allow producers to recover gracefully from transaction timeouts
Page:
KIP-30 - Allow for brokers to have plug-able consensus and meta data storage sub systems
Page:
KIP-18 - JBOD Support
Page:
KIP-446: Add changelog topic configuration to KTable suppress
Page:
KIP-345: Introduce static membership protocol to reduce consumer rebalances
Page:
KIP-865: Support --bootstrap-server in kafka-streams-application-reset
Page:
KIP-683: Add recursive support to Connect Cast and ReplaceField transforms, and support for casting complex types to either a native or JSON string
Page:
KIP-1002: Fetch remote segment indexes at once
Page:
KIP-581: Value of optional null field which has default value
Page:
KIP-116: Add State Store Checkpoint Interval Configuration
Page:
KIP-127: Pluggable JAAS LoginModule configuration for SSL
Page:
KIP-298: Error Handling in Connect
Page:
KIP-546: Add Client Quota APIs to the Admin Client
Page:
KIP-494: Connect REST Endpoint to get Transformations (SMTs)
Page:
KIP-395: Encypt-then-MAC Delegation token metadata
Page:
KIP-215: Add topic regex support for Connect sinks
Page:
KIP-193: Add SchemaBuilder.from(Schema)
Page:
KIP-986: Cross-Cluster Replication
Page:
KIP-630: Kafka Raft Snapshot
Page:
KIP-496: Administrative API to delete consumer offsets
Page:
KIP-250 Add Support for Quorum-based Producer Acknowledgment
Page:
KIP-962: Relax non-null key requirement in Kafka Streams
Page:
KIP-881: Rack-aware Partition Assignment for Kafka Consumers
Page:
KIP-868 Metadata Transactions
Page:
KIP-864: Add End-To-End Latency Metrics to Connectors
Page:
KIP-682: Connect TimestampConverter support for multiple fields and multiple input formats
Page:
KIP-570: Add leader epoch in StopReplicaRequest
Page:
KIP-330: Add retentionPeriod in SessionBytesStoreSupplier
Page:
KIP-1012: The need for a Kafka 3.8.x release
Page:
KIP-605: Expand Connect Worker Internal Topic Settings
Page:
KIP-654: Aborted transaction with non-flushed data should throw a non-fatal exception
Page:
KIP-441: Smooth Scaling Out for Kafka Streams
Page:
KIP-589 Add API to update Replica state in Controller
Page:
KIP-420: Add Single Value Fetch in Session Stores
Page:
KIP-691: Enhance Transactional Producer Exception Handling
Page:
KIP-429: Kafka Consumer Incremental Rebalance Protocol
Page:
KIP-1005: Expose EarliestLocalOffset and TieredOffset
Page:
KIP-457: Add DISCONNECTED status to Kafka Streams
Page:
KIP-794: Strictly Uniform Sticky Partitioner
Page:
KIP-594: Expose output topic names from TopologyTestDriver
Page:
KIP-695: Further Improve Kafka Streams Timestamp Synchronization
Page:
KIP-817: Fix inconsistency in dynamic application log levels
Page:
KIP-983: Full speed async processing during rebalance
Page:
KIP-305: Add Connect primitive number converters
Page:
KIP-787: MM2 manage Kafka resources with custom Admin implementation.
Page:
KIP-992: Proposal to introduce IQv2 Query Types: TimestampedKeyQuery and TimestampedRangeQuery
Page:
KIP-580: Exponential Backoff for Kafka Clients
Page:
KIP-553: Disable all SSL protocols except TLSV1.2 by default.
Page:
KIP-749: Add --files and --file-separator options to the ConsoleProducer
Page:
KIP-730: Producer ID generation in KRaft mode
Page:
KIP-835: Monitor KRaft Controller Quorum Health
Page:
KIP-745: Connect API to restart connector and tasks
Page:
KIP-531: Drop support for Scala 2.11 in Kafka 2.5
Page:
KIP-948: Allow custom prefix for internal topic names in Kafka Streams
Page:
KIP-244: Add Record Header support to Kafka Streams Processor API
Page:
KIP-617: Allow Kafka Streams State Stores to be iterated backwards
Page:
KIP-335: Consider configurations for KafkaStreams
Page:
KIP-484: Expose metrics for group and transaction metadata loading duration
Page:
KIP-148: Add a connect timeout for client
Page:
KIP-604: Remove ZooKeeper Flags from the Administrative Tools
Page:
KIP-414: Expose Embedded ClientIds in Kafka Streams
Page:
KIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint
Page:
KIP-820: Extend KStream process with new Processor API
Page:
KIP-402: Improve fairness in SocketServer processors
Page:
KIP-1013: Drop broker and tools support for Java 11 in Kafka 4.0 (deprecate in 3.7)
Page:
KIP-953: partition method to be overloaded to accept headers as well.
Page:
KIP-573: Enable TLSv1.3 by default
Page:
KIP-353: Improve Kafka Streams Timestamp Synchronization
Page:
KIP-592: MirrorMaker 1.0 should replicate topics from earliest
Page:
KIP-540: Implement per key stream time tracking
Page:
KIP-288: [DISCARDED] Consumer.poll() timeout semantic change and new waitForAssignment method
Page:
KIP-263: Allow broker to skip sanity check of inactive segments on broker startup
Page:
KIP-852: Optimize calculation of size for log in remote tier
Page:
KIP-767: Connect Latency Metrics
Page:
KIP-680: TopologyTestDriver should not require a Properties argument
Page:
KIP-673: Emit JSONs with new auto-generated schema
Page:
KIP-963: Additional metrics in Tiered Storage
Page:
KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines
Page:
KIP-242: Mask password in Kafka Connect Rest API response
Page:
KIP-547: Extend ConsumerInterceptor to allow modification of Consumer Commits
Page:
KIP-597: MirrorMaker2 internal topics Formatters
Page:
KIP-575: build a Kafka-Exporter by Java
Page:
KIP-700: Add Describe Cluster API
Page:
KIP-752: Support --bootstrap-server in ReplicaVerificationTool
Page:
KIP-217: Expose a timeout to allow an expired ZK session to be re-created
Page:
KIP-571: Add option to force remove members in StreamsResetter
Page:
KIP-297: Externalizing Secrets for Connect Configurations
Page:
KIP-993: Allow restricting files accessed by File and Directory ConfigProviders
Page:
KIP-246: Connect producers and consumers should inherit worker configs
Page:
KIP-278 - Add version option to Kafka's commands
Page:
KIP-848: The Next Generation of the Consumer Rebalance Protocol
Page:
KIP-555: Deprecate Direct Zookeeper access in Kafka Administrative Tools
Page:
KIP-849: Expose logdirs total and usable space via kafka-log-dirs.sh
Page:
KIP-814: Static membership protocol should let the leader skip assignment
Page:
KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver
Page:
KIP-458: Connector Client Config Override Policy
Page:
KIP-631: The Quorum-based Kafka Controller
Page:
KIP-714: Client metrics and observability
Page:
KIP-471: Expose RocksDB Metrics in Kafka Streams
Page:
KIP-738: Removal of Connect's internal converter properties
Page:
KIP-356: Add KafkaConsumer fetch-error-rate and fetch-error-total metrics
Page:
KIP-705: Selectively Disable Topology Optimizations
Page:
KIP-521: Enable redirection of Connect's log4j messages to a file by default
Page:
KIP-451: Make TopologyTestDriver output iterable
Page:
KIP-488: Clean up Sum,Count,Total Metrics
Page:
KIP-1010: Topic Partition Quota
Page:
KIP-524: Allow users to choose config source when describing configs
Page:
KIP-821: Connect Transforms support for nested structures
Page:
KIP-584: Versioning scheme for features
Page:
KIP-919: Allow AdminClient to Talk Directly with the KRaft Controller Quorum and add Controller Registration
Page:
KIP-313: Add KStream.flatTransform and KStream.flatTransformValues
Page:
KIP-951: Leader discovery optimisations for the client
Page:
KIP-996: Pre-Vote
Page:
KIP-645: Replace Windows with a proper interface
Page:
KIP-614: Add Prefix Scan support for State Stores
Page:
KIP-779: Allow Source Tasks to Handle Producer Exceptions
Page:
KIP-725: Streamlining configurations for WindowedSerializer and WindowedDeserializer.
Page:
KIP-422: Add support for client quota configuration in the Kafka Admin Client
Page:
KIP-53 - Add custom policies for reconnect attempts to NetworkdClient
Page:
KIP-5 - Broker Configuration Management
Page:
KIP-135 : Send of null key to a compacted topic should throw non-retriable error back to user
Page:
KIP-374: Add '--help' option to all available Kafka CLI commands
Page:
KIP-27 - Conditional Publish
Page:
KIP-331 Add default implementation to close() and configure() for Serializer, Deserializer and Serde
Page:
KIP-490: New metric to count offsets expired without being consumed by a consumer group
Page:
KIP-419: Safely notify Kafka Connect SourceTask is stopped
Page:
KIP-692: Make AdminClient value object constructors public
Page:
KIP-317: Add end-to-end data encryption functionality to Apache Kafka
Page:
KIP-316: Command-line overrides for ConnectDistributed worker properties
Page:
KIP 771: KRaft brokers without the "controller" role should not expose controller metrics
Page:
KIP-259: Improve Streams DSL Timestamp Propagation Semantics
Page:
KIP-687: Automatic Reloading of Security Store
Page:
KIP-586: Deprecate commit records without record metadata
Page:
KIP-875: First-class offsets support in Kafka Connect
Page:
KIP-904: Kafka Streams - Guarantee subtractor is called before adder if key has not changed
Page:
KIP-199: Add Kafka Connect offset tool
Page:
KIP-655: Windowed Distinct Operation for Kafka Streams API
Page:
KIP-430 - Return Authorized Operations in Describe Responses
Page:
KIP-610: Error Reporting in Sink Connectors
Page:
KIP-780: Support fine-grained compression options
Page:
KIP-629: Use racially neutral terms in our codebase
Page:
KIP-460: Admin Leader Election RPC
Page:
KIP-697: Stricter parsing of addresses in configs
Page:
KIP-806: Add session and window query over kv-store in IQv2
Page:
KIP-915: Txn and Group Coordinator Downgrade Foundation
Page:
KIP-710: Full support for distributed mode in dedicated MirrorMaker 2.0 clusters
Page:
KIP-777: Improved testability for Admin client
Page:
KIP-332: Update AclCommand to use AdminClient API
Page:
KIP-389: Introduce a configurable consumer group size limit
Page:
KIP-939: Support Participation in 2PC
Page:
KIP-859: Add Metadata Log Processing Error Related Metrics
Page:
KIP-535: Allow state stores to serve stale reads during rebalance
Page:
KIP-34 Add Partitioner Change Listener to Partitioner Interface for Multiple Use Case
Page:
KIP-400: Improve exit status in case of errors in ConsoleProducer
Page:
KIP-47 - Add timestamp-based log deletion policy
Page:
KIP-808: Add support for different unix precisions in TimestampConverter SMT
Page:
KIP-383: Pluggable interface for SSL Factory
Page:
KIP-296: Connector level configurability for client configs
Page:
KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum
Page:
KIP-309: Add toUpperCase support to sasl.kerberos.principal.to.local rule
Page:
KIP-796: Interactive Query v2
Page:
KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file
Page:
KIP-248 - Create New ConfigCommand That Uses The New AdminClient
Page:
KIP-271: Add NetworkClient redirector
Page:
KIP-423: Add JoinReason to Consumer Join Group Protocol
Page:
KIP-621: Deprecate and replace DescribeLogDirsResult.all() and .values()
Page:
KIP-435: Internal Partition Reassignment Batching
Page:
KIP-324: Add method to get metrics() in AdminClient
Page:
KIP-607: Add Metrics to Kafka Streams to Report Properties of RocksDB
Page:
KIP-952: Regenerate segment-aligned producer snapshots when upgrading to a Kafka version supporting Tiered Storage
Page:
KIP-325: Extend Consumer Group Command to Show Beginning Offsets
Page:
KIP-559: Make the Kafka Protocol Friendlier with L7 Proxies
Page:
KIP-946: Modify exceptions thrown by Consumer APIs
Page:
KIP-303: Add Dynamic Routing in Streams Sink
Page:
KIP-454: Expansion of the ConnectClusterState interface
Page:
KIP-392: Allow consumers to fetch from closest replica
Page:
KIP-372: Naming Repartition Topics for Joins and Grouping
Page:
KIP-184: Rename LogCleaner and related classes to LogCompactor
Page:
KIP-876: Time based cluster metadata snapshots
Page:
KIP-606: Add Metadata Context to MetricsReporter
Page:
KIP-663: API to Start and Shut Down Stream Threads
Page:
Kafka Streams
Page:
KIP-301: Schema Inferencing for JsonConverter
Page:
KIP-638: Deprecate DescribeLogDirsResponse.[LogDirInfo, ReplicaInfo]
Page:
KIP-286: producer.send() should not block on metadata update
Page:
KIP-403: Increase ProducerPerformance precision by using nanoTime
Page:
KIP-68 Add a consumed log retention before log retention
Page:
KIP-634: Complementary support for headers and record metadata in Kafka Streams DSL
Page:
KIP-618: Exactly-Once Support for Source Connectors
Page:
KIP-307: Allow to define custom processor names with KStreams DSL
Page:
KIP-1003: Signal next segment when remote fetching
Page:
KIP-444: Augment metrics for Kafka Streams
Page:
KIP-878: Internal Topic Autoscaling for Kafka Streams
Page:
KIP-684 - Support mutual TLS authentication on SASL_SSL listeners
Page:
KIP-503: Add metric for number of topics marked for deletion
Page:
KIP-468: Avoid decompression of record when validate record at server in the scene of inPlaceAssignment .
Overview
Content Tools
Apps
{"serverDuration": 2177, "requestCorrelationId": "d345f2084e297114"}