This Confluence has been LDAP enabled, if you are an ASF Committer, please use your LDAP Credentials to login. Any problems file an INFRA jira ticket please.

Child pages
  • Kafka Improvement Proposals
535 more child pages
Title: Kafka Improvement Proposals  
Author: Jay Kreps Jan 15, 2015
Last Changed by: Mykhailo Yeromenko Oct 21, 2019
Tiny Link: (useful for email) https://cwiki.apache.org/confluence/x/4QwIAw
Export As: Word · PDF  
Incoming Links
CASSANDRA (1)
    Page: CEP-Template
Apache Kafka (47)
    Page: KIP-278 - Add version option to Kafka's commands
    Page: KIP-436: Add a metric indicating start time
    Page: KIP-332: Update AclCommand to use AdminClient API
    Page: 489: Kafka Consumer Record Latency Metric
    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-499 - Unify connection name flag for command line tool
    Page: KIP-187 - Add cumulative count metric for all Kafka rate metrics
    Page: KIP-NEXT: Get rid of unnecessary read lock
    Page: KIP-Template
    Page: KIP-241 KTable repartition with compacted Topics
    Page: KIP-294 - Enable TLS hostname verification by default
    Page: KIP-420: Add Single Value Fetch in Session Stores
    Page: Release Plan 0.11.0.0
    Page: KIP-176: Remove deprecated new-consumer option for tools
    Page: KIP-348 Deprecate null from SourceTask#poll()
    Page: KIP-403: Increase ProducerPerformance precision by using nanoTime
    Page: KIP-23 - Add JSON/CSV output and looping options to ConsumerGroupCommand
    Page: KIP-367 Introduce close(Duration) to Producer and AdminClient instead of close(long, TimeUnit)
    Page: KIP-188 - Add new metrics to support health checks
    Page: KIP-357: Add support to list ACLs per principal
    Page: KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule
    Page: KIP-330: Add retentionPeriod in SessionBytesStoreSupplier
    Page: KIP-113: Support replicas movement between log directories
    Page: KIP-395: Encypt-then-MAC Delegation token metadata
    Page: KIP-59: Proposal for a kafka broker command
    Page: KIP-363: Allow performance tools to print final results to output file
    Page: KIP-483: Add Broker Version API in Admin Client
    Page: KIP-250 Add Support for Quorum-based Producer Acknowledgment
    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: Release Plan 1.1.0 (2018 Feb.)
    Page: KIP-254: JsonConverter Exception Handeling
    Home page: Index
    Page: KIP-451: Make TopologyTestDriver output iterable
    Page: Contributing Code Changes
    Page: KIP-327: Add describe all topics API to AdminClient
    Page: KIP-432: Additional Broker-Side Opt-In for Default, Unsecure SASL/OAUTHBEARER Implementation
    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-NEXT: Add support of quota configuration in the KafkaAdminClient
    Page: KIP-DRAFT: Error Handling in Connect
    Page: KIP-506: Allow setting SCRAM password via Admin interface
    Page: Release Plan 1.0.0 (2017 Oct.)
    Page: KIP-322: Return new error code for DeleteTopics API when topic deletion disabled.
    Page: KIP-344: The auto-generated client id should be passed to MetricsReporter
Hierarchy
Parent Page
    Home page: Index
Children (538)
    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
Labels
There are no labels assigned to this page.
Outgoing Links
External Links (311)
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-203%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP+157+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-35+-+…
    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/pages/viewpage.action?p…
    https://github.com/apache/kafka/pull/99
    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-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-120%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-75+-+…
    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-378%3…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    https://youtu.be/_QWogr9OngE
    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-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-33+-+…
    https://youtu.be/UcUcT0wYlzY
    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-91+Pr…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-16+-+…
    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-238%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP+130%3…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-182%3…
    https://youtu.be/6v9iBPij3wg
    https://www.mail-archive.com/dev@kafka.apache.org/msg100621…
    https://www.youtube.com/watch?v=rFW0-zJqg5I&feature=youtu.b…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-108%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-466%3…
    https://youtu.be/APlWPNxiq7A
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-195%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-2+-+R…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-92+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-152+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-276+A…
    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-129%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-78%3A…
    https://github.com/apache/kafka/pull/130
    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-201%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-437%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-354%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-124+-…
    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://cwiki.apache.org/confluence/display/KAFKA/KIP-46%3A…
    https://youtu.be/Hcjur17TjBE
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-224%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-105%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-406%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-3+-+M…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-387%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-189%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-237%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-84%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-177%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-14+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-539%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-19+-+…
    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-54+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-103%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-96+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-171+-…
    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/display/KAFKA/KIP-222+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-138%3…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    kafka.apache.org/contact
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-207%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-393%3…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    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-168%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-410%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-58+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-436%3…
    https://youtu.be/AyG_rUowEis
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-197+C…
    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-86%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-115%3…
    https://youtu.be/RyyTCVCl9BA
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-71%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-426%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-192+%…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-8+-+A…
    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-162+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-283%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-522%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-267%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-85%3A…
    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-190%3…
    https://issues.apache.org/jira/browse/KAFKA-3663
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-347%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-188+-…
    https://youtu.be/GcG91l7FQ3c
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-66%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-41%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-80%3A…
    https://www.mail-archive.com/dev@kafka.apache.org/msg102178…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-290%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-257+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-220%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-21+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-42%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-140%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-214%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-165%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-143%3…
    https://www.youtube.com/watch?v=ko34LJEr4wA
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-+22+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-236%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-272%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-77%3A…
    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-453%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-219+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-411%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-509%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-513%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-187+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-364%3…
    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-266%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-373%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-245%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-100+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-63%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/489%3A+Ka…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-48+De…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-1+-+R…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-371%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-338+S…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-377%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-88%3A…
    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-32+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-191%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-90+-+…
    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-145+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-284%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-351%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-150+-…
    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-13+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-361%3…
    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://cwiki.apache.org/confluence/display/KAFKA/KIP-357%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-101+-…
    https://www.youtube.com/watch?v=1ZMjimctFCs&feature=youtu.b…
    https://cwiki.apache.org/confluence/display/KAFKA/Bylaws#By…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-52%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-133%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-160%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-534%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/pages/viewpage.action?p…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-109%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+155+-…
    https://youtu.be/GN-i9Vq-J5k
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-327%3…
    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-240%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-421%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-67%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-408%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP+269+S…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-281%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-261%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-51+-+…
    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-175%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-461+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-379%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-233%3…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-131+-…
    https://cwiki.apache.org/confluence/pages/viewpage.action?p…
    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-106+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-70%3A…
    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-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-102+-…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-60+-+…
    https://youtu.be/WIoiQBi_lsE
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-312%3…
    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-55%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-253%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-211%3…
    https://issues.apache.org/jira/browse/KAFKA-4090
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-38%3A…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-178%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-360%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-73+Re…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-320%3…
    https://youtu.be/MCnS8OB2-v4
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-31+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-479%3…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-20+-+…
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-117%3…
    https://www.youtube.com/watch?v=fr55FooRXpI
    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…
    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+-+…
Apache Kafka (236)     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-216: IQ should throw different exceptions for different errors
    Page: KIP-473: Enable KafkaLog4JAppender to use SASL Authentication Callback Handlers
    Page: KIP-44 - Allow Kafka to have a customized security protocol
    Page: KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils
    Page: KIP-306: Configuration for Delaying Response to Failed Client Authentication
    Page: KIP-17 - Add HighwaterMarkOffset to OffsetFetchResponse
    Page: KIP-409: Allow creating under-replicated topics and partitions
    Page: KIP-525 - Return topic metadata and configs in CreateTopics response
    Page: KIP-438: Expose task, connector IDs in Connect API
    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-434: Add Replica Fetcher and Log Cleaner Count Metrics
    Page: KIP-455: Create an Administrative API for Replica Reassignment
    Page: KIP-258: Allow to Store Record Timestamps in RocksDB
    Page: KIP-530: Consider renaming 'UsePreviousTimeOnInvalidTimeStamp' class to 'UsePartitionTimeOnInvalidTimeStamp'
    Page: KIP-486: Support custom way to load KeyStore and TrustStore
    Page: KIP-431: Support of printing additional ConsumerRecord fields in DefaultMessageFormatter
    Page: KIP-275 - Indicate "isClosing" in the SinkTaskContext
    Page: KIP-142: Add ListTopicsRequest to efficiently list all the topics in a cluster
    Page: KIP-270 - A Scala Wrapper Library for Kafka Streams
    Page: KIP-475: New Metrics to Measure Number of Tasks on a Connector
    Page: KIP-333: Add faster mode of rebalancing
    Page: KIP-399: Extend ProductionExceptionHandler to cover serialization exceptions
    Page: KIP-447: Producer scalability for exactly once semantics
    Page: KIP 141 - ProducerRecord & SourceRecord: Add timestamp constructors
    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-366: Make FunctionConversions deprecated
    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-358: Migrate Streams API to Duration instead of long ms times
    Page: KIP-440: Extend Connect Converter to support headers
    Page: KIP-24 - Remove ISR information from TopicMetadataRequest and add broker level metadata request
    Page: KIP-201: Rationalising Policy interfaces
    Page: KIP-481: SerDe Improvements for Connect Decimal type in JSON
    Page: KIP-502: Connect Task Method Signature to be More Specific for Developers
    Page: KIP-385: Avoid throwing away prefetched data
    Page: KIP-87 - Add Compaction Tombstone Flag
    Page: KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde
    Page: KIP-6 - New reassignment partition logic for rebalancing
    Page: KIP-30 - Allow for brokers to have plug-able consensus and meta data storage sub systems
    Page: KIP-497: Add inter-broker API to alter ISR
    Page: KIP-169 - Lag-Aware Partition Assignment Strategy
    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-280: Enhanced log compaction
    Page: KIP-527: Add VoidSerde to Serdes
    Page: KIP-110: Add Codec for ZStandard Compression
    Page: KIP-209 - Connection String Support
    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-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-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-277 - Fine Grained ACL for CreateTopics API
    Page: KIP-425: Add some Log4J Kafka Appender Properties for Producing to Secured Brokers
    Page: KIP-496: Administrative API to delete consumer offsets
    Page: KIP-250 Add Support for Quorum-based Producer Acknowledgment
    Page: KIP-160: Augment KStream.print(), KStream.writeAsText() to allow users pass in extra parameters in the printed string
    Page: KIP-330: Add retentionPeriod in SessionBytesStoreSupplier
    Page: KIP-441: Smooth Scaling Out for Kafka Streams
    Page: KIP-533: Add default api timeout to AdminClient
    Page: KIP-170: Enhanced TopicCreatePolicy and introduction of TopicDeletePolicy
    Page: KIP-507: Securing Internal Connect REST Endpoints
    Page: KIP-420: Add Single Value Fetch in Session Stores
    Page: KIP 172: Add regular-expression topic support for sink connector
    Page: KIP-429: Kafka Consumer Incremental Rebalance Protocol
    Page: KIP-457: Add DISCONNECTED status to Kafka Streams
    Page: KIP-508: Make Suppression State Queriable
    Page: KIP-321: Update TopologyDescription to better represent Source and Sink Nodes
    Page: KIP-470: TopologyTestDriver test input and output usability improvements
    Page: KIP-305: Add Connect primitive number converters
    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-315: Stream Join Sticky Assignor
    Page: KIP-531: Drop support for Scala 2.11 in Kafka 2.5
    Page: KIP-244: Add Record Header support to Kafka Streams Processor API
    Page: KIP-335: Consider configurations for KafkaStreams
    Page: KIP-37 - Add Namespaces to Kafka
    Page: KIP-484: Expose metrics for group and transaction metadata loading duration
    Page: KIP-148: Add a connect timeout for client
    Page: KIP-166 - Add a tool to make amounts of replicas and leaders on brokers balanced
    Page: KIP-319: Replace segments with segmentInterval in WindowBytesStoreSupplier
    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-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-414: Expose Embedded ClientIds in Kafka Streams
    Page: KIP-485: Make topic optional when using through() operations in DSL
    Page: KIP-221: Enhance DSL with Connecting Topic Creation and Repartition Hint
    Page: KIP-402: Improve fairness in SocketServer processors
    Page: KIP-412: Extend Admin API to support dynamic application log levels
    Page: KIP-353: Improve Kafka Streams Timestamp Synchronization
    Page: KIP-339: Create a new IncrementalAlterConfigs API
    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-528: Deprecate PartitionGrouper configuration and interface
    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-266: Fix consumer indefinite blocking behavior
    Page: KIP-538: Add a metric tracking the number of open connections with a given SSL cipher type
    Page: KIP-415: Incremental Cooperative Rebalancing in Kafka Connect
    Page: KIP-476: Add Java AdminClient Interface
    Page: KIP-499: Create a controller RPC for changing configurations
    Page: KIP-217: Expose a timeout to allow an expired ZK session to be re-created
    Page: KIP-297: Externalizing Secrets for Connect Configurations
    Page: KIP-516: Topic Identifiers
    Page: KIP-163: Lower the Minimum Required ACL Permission of OffsetFetch
    Page: KIP-246: Connect producers and consumers should inherit worker configs
    Page: KIP-278 - Add version option to Kafka's commands
    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-208: Add SSL support to Kafka Connect REST interface
    Page: KIP-352: Distinguish URPs caused by reassignment
    Page: KIP-456: Helper classes to make it simpler to write test logic with TopologyTestDriver
    Page: KIP-536: Propagate broker timestamp to Admin API
    Page: KIP-458: Connector Client Config Override Policy
    Page: KIP-471: Expose RocksDB Metrics in Kafka Streams
    Page: KIP-394: Require member.id for initial join group request
    Page: KIP-452: Tool to view cluster status
    Page: KIP-326: Schedulable KTable as Graph source
    Page: KIP-356: Add KafkaConsumer fetch-error-rate and fetch-error-total metrics
    Page: KIP-521: Enable redirection of Connect's log4j messages to a file by default
    Page: KIP-451: Make TopologyTestDriver output iterable
    Page: KIP-477: Add PATCH method for connector config in Connect REST API
    Page: KIP-488: Clean up Sum,Count,Total Metrics
    Page: KIP-294 - Enable TLS hostname verification by default
    Page: KIP-524: Allow users to choose config source when describing configs
    Page: KIP 230: Name Windowing Joins
    Page: KIP-313: Add KStream.flatTransform and KStream.flatTransformValues
    Page: KIP-505: Add new public method to only update assignment metadata in consumer
    Page: KIP-465: Add Consolidated Connector Endpoint to Connect REST API
    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-466: Add support for List<T> serialization and deserialization
    Page: KIP-5 - Broker Configuration Management
    Page: KIP-449: Add connector contexts to Connect worker logs
    Page: KIP-495: Dynamically Adjust Log Levels in Connect
    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-304: Connect runtime mode improvements for container platforms
    Page: KIP-213 Support non-key joining in KTable
    Page: KIP-390: Allow fine-grained configuration for compression
    Page: KIP-317: Add end-to-end data encryption functionality to Apache Kafka
    Page: KIP-370: Remove Orphan Partitions
    Page: KIP-316: Command-line overrides for ConnectDistributed worker properties
    Page: KIP-442: Return to default max poll interval in Streams
    Page: KIP-356: Add withCachingDisabled() to StoreBuilder
    Page: KIP-259: Improve Streams DSL Timestamp Propagation Semantics
    Page: KIP-462: Use local thread id for KStreams
    Page: Old KIP-179 - Change ReassignPartitionsCommand to use AdminClient
    Page: KIP-199: Add Kafka Connect offset tool
    Page: KIP-498: Add client-side configuration for maximum response size to protect against OOM
    Page: KIP-430 - Return Authorized Operations in Describe Responses
    Page: KIP-49 - Fair Partition Assignment Strategy
    Page: KIP-460: Admin Leader Election RPC
    Page: KIP-463: Auto-configure non-default Serdes passed alongside the TopologyBuilder
    Page: KIP-314: KTable to GlobalKTable Bi-directional Join
    Page: KIP-360: Improve handling of unknown producer
    Page: KIP-332: Update AclCommand to use AdminClient API
    Page: KIP-389: Introduce a configurable consumer group size limit
    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-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-234: add support for getting topic defaults from AdminClient
    Page: KIP-309: Add toUpperCase support to sasl.kerberos.principal.to.local rule
    Page: KIP-369: Alternative Partitioner to Support "Always Round-Robin" Selection
    Page: KIP-39 Pinning controller to broker
    Page: KIP-340: Allow kafka-reassign-partitions.sh and kafka-log-dirs.sh to take admin client property file
    Page: KIP-517: Add consumer metrics to observe user poll behavior
    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-435: Internal Partition Reassignment Batching
    Page: KIP-324: Add method to get metrics() in AdminClient
    Page: KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics
    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-325: Extend Consumer Group Command to Show Beginning Offsets
    Page: KIP-388: Add observer interface to record request and response
    Page: KIP-382: MirrorMaker 2.0
    Page: KIP-7 - Security - IP Filtering
    Page: KIP-303: Add Dynamic Routing in Streams Sink
    Page: KIP-537: Increase default zookeeper session timeout
    Page: KIP-454: Expansion of the ConnectClusterState interface
    Page: KIP-384: Add config for incompatible changes to persistent metadata
    Page: KIP-9 - SSL Support
    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-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-518: Allow listing consumer groups per state
    Page: Kafka Streams
    Page: KIP-125: ZookeeperConsumerConnector to KafkaConsumer Migration and Rollback
    Page: KIP-301: Schema Inferencing for JsonConverter
    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-428: Add in-memory window store
    Page: KIP-397: Add methods to override fetch offsets based on timestamp
    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-307: Allow to define custom processor names with KStreams DSL
    Page: KIP-444: Augment metrics for Kafka Streams
    Page: KIP-282: Add the listener name to the authentication context
    Page: KIP-328: Ability to suppress updates for KTables
    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 .