zoukankan      html  css  js  c++  java
  • Kafka Zookeeper Quorum【Self-Managed Metadata】演进历史关键信息

    3.0.0
    Released September 21, 2021
    Release Notes
    Source download: kafka-3.0.0-src.tgz (asc, sha512)
    Binary downloads:
    Scala 2.12 - kafka_2.12-3.0.0.tgz (asc, sha512)
    Scala 2.13 - kafka_2.13-3.0.0.tgz (asc, sha512)
    We build for multiple versions of Scala. This only matters if you are using Scala and you want a version built for the same Scala version you use. Otherwise any version should work (2.13 is recommended).
    Kafka 3.0.0 includes a number of significant new features. Here is a summary of some notable changes:

    The deprecation of support for Java 8 and Scala 2.12
    Kafka Raft support for snapshots of the metadata topic and other improvements in the self-managed quorum
    Stronger delivery guarantees for the Kafka producer enabled by default
    Deprecation of message formats v0 and v1
    Optimizations in OffsetFetch and FindCoordinator requests
    More flexible Mirror Maker 2 configuration and deprecation of Mirror Maker 1
    Ability to restart a connector's tasks on a single call in Kafka Connect
    Connector log contexts and connector client overrides are now enabled by default
    Enhanced semantics for timestamp synchronization in Kafka Streams
    Revamped public API for Stream's TaskId
    Default serde becomes null in Kafka
    For more information, please read the detailed Release Notes.

    2.8.0
    Released April 19, 2021
    Release Notes
    Source download: kafka-2.8.0-src.tgz (asc, sha512)
    Binary downloads:
    Scala 2.12 - kafka_2.12-2.8.0.tgz (asc, sha512)
    Scala 2.13 - kafka_2.13-2.8.0.tgz (asc, sha512)
    We build for multiple versions of Scala. This only matters if you are using Scala and you want a version built for the same Scala version you use. Otherwise any version should work (2.13 is recommended).
    Kafka 2.8.0 includes a number of significant new features. Here is a summary of some notable changes:

    Early access of replace ZooKeeper with a self-managed quorum
    Add Describe Cluster API
    Support mutual TLS authentication on SASL_SSL listeners
    JSON request/response debug logs
    Limit broker connection creation rate
    Topic identifiers
    Expose task configurations in Connect REST API
    Update Streams FSM to clarify ERROR state meaning
    Extend StreamJoined to allow more store configs
    More convenient TopologyTestDriver construtors
    Introduce Kafka-Streams-specific uncaught exception handler
    API to start and shut down Streams threads
    Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size
    Improve timeouts and retries in Kafka Streams
    For more information, please read the detailed Release Notes.

    2.5.0
    Released April 15, 2020
    Release Notes
    Source download: kafka-2.5.0-src.tgz (asc, sha512)
    Binary downloads:
    Scala 2.12 - kafka_2.12-2.5.0.tgz (asc, sha512)
    Scala 2.13 - kafka_2.13-2.5.0.tgz (asc, sha512)
    We build for multiple versions of Scala. This only matters if you are using Scala and you want a version built for the same Scala version you use. Otherwise any version should work (2.12 is recommended).
    Kafka 2.5.0 includes a number of significant new features. Here is a summary of some notable changes:

    TLS 1.3 support (1.2 is now the default)
    Co-groups for Kafka Streams
    Incremental rebalance for Kafka Consumer
    New metrics for better operational insight
    Upgrade Zookeeper to 3.5.7
    Deprecate support for Scala 2.11
    For more information, please read the detailed Release Notes.

    2.4.1
    Released March 12, 2020
    Release Notes
    Source download: kafka-2.4.1-src.tgz (asc, sha512)
    Binary downloads:
    Scala 2.11 - kafka_2.11-2.4.1.tgz (asc, sha512)
    Scala 2.12 - kafka_2.12-2.4.1.tgz (asc, sha512)
    Scala 2.13 - kafka_2.13-2.4.1.tgz (asc, sha512)
    We build for multiple versions of Scala. This only matters if you are using Scala and you want a version built for the same Scala version you use. Otherwise any version should work (2.12 is recommended).
    For more information, please read the detailed Release Notes.

    2.4.0
    Released December 16, 2019
    Release Notes
    Source download: kafka-2.4.0-src.tgz (asc, sha512)
    Binary downloads:
    Scala 2.11 - kafka_2.11-2.4.0.tgz (asc, sha512)
    Scala 2.12 - kafka_2.12-2.4.0.tgz (asc, sha512)
    Scala 2.13 - kafka_2.13-2.4.0.tgz (asc, sha512)
    We build for multiple versions of Scala. This only matters if you are using Scala and you want a version built for the same Scala version you use. Otherwise any version should work (2.12 is recommended).
    Kafka 2.4.0 includes a number of significant new features. Here is a summary of some notable changes:

    Allow consumers to fetch from closest replica.
    Support for incremental cooperative rebalancing to the consumer rebalance protocol.
    MirrorMaker 2.0 (MM2), a new multi-cluster, cross-datacenter replication engine.
    New Java authorizer Interface.
    Support for non-key joining in KTable.
    Administrative API for replica reassignment.
    For more information, please read the detailed Release Notes.

    Kafka将逐步弃用对zookeeper的依赖_黑曼巴-CSDN博客
    https://blog.csdn.net/yangyijun1990/article/details/111874645

    KIP-500: Replace ZooKeeper with a Self-Managed Metadata Quorum - Apache Kafka - Apache Software Foundation
    https://cwiki.apache.org/confluence/display/KAFKA/KIP-500:+Replace+ZooKeeper+with+a+Self-Managed+Metadata+Quorum

    Index - Apache Kafka - Apache Software Foundation
    https://cwiki.apache.org/confluence/display/KAFKA/Index

    Kafka Internals - Apache Kafka - Apache Software Foundation
    https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Internals

    Kafka mirroring (MirrorMaker) - Apache Kafka - Apache Software Foundation
    https://cwiki.apache.org/confluence/display/KAFKA/Kafka+mirroring+(MirrorMaker)

  • 相关阅读:
    【自制操作系统03】读取硬盘中的数据
    【自制操作系统02】环境准备与启动区实现
    【自制操作系统01】硬核讲解计算机的启动过程
    【30天自制操作系统】day06:中断
    java8 stream ,filter 等功能代替for循环
    如何评估工作量--三点估算
    python 错误AttributeError: 'module' object has no attribute 'AF_INET'
    python入门学习
    mysql5.7.10和mysql5.5.39两个版本对于group by函数的处理差异
    jenkins 构建时,取消构建测试类
  • 原文地址:https://www.cnblogs.com/rgqancy/p/15307515.html
Copyright © 2011-2022 走看看