5.5. 弃用和删除 Kafka 功能

本节提前通知 Apache Kafka 项目中的重要弃用和删除。

5.5.1. 计划在 Kafka 版本 3.0 中删除

Kafka 版本 3.0 将随 AMQ Streams 下一个主发行版本一起提供。

下表显示了在 Kafka 2.x 或更早版本中弃用且将在 Kafka 3.0 中删除 的方法和组件。这份清单并非详尽。

表 5.1. 弃用了将在 Kafka 3.0 中删除的 API 方法和组件

API 或组件问题链接描述

管理 API

KAFKA-12581

删除已弃用的 Admin.electPreferredLeaders

管理 API

KAFKA-6987

使用 CompletableFuture 重新实施 KafkaFuture(弃用 KafkaFuture.Function)

管理客户端

KAFKA-12577

删除已弃用的 ConfigEntry 构造器

所有客户端

KAFKA-12579

从客户端的 3.0 中删除各种弃用方法

所有客户端

KAFKA-12600

删除客户端配置客户端. dns.lookup的已弃用配置值 默认值

所有客户端

KAFKA-12578

删除已弃用的安全类/methods

broker

KAFKA-12591

删除已弃用的 quota.producer.defaultquota.consumer.default 配置

broker

KAFKA-12592

删除已弃用的 LogConfig.Compact

broker

KAFKA-12590

Remove deprecated SimpleAclAuthorizer

broker

KAFKA-5905

删除 PrincipalBuilder 和 DefaultPrincipalBuilder

common

KAFKA-12573

删除了 deprecated Metric#value

使用者 API

KAFKA-12637

删除已弃用的 PartitionAssignor 接口

连接 API

KAFKA-12482

删除已弃用的 rest.host.name 和 rest.port Connect worker 配置

连接 API

KAFKA-12945

删除 3.0 中的端口、host.name 和相关配置

连接 API

KAFKA-12717

删除内部转换器配置属性

Streams API

KAFKA-12574

弃用 eos-alpha

Streams API

KAFKA-12808

删除 StreamsMetrics 下已弃用的方法

Streams API

KAFKA-7606

从 StreamsResetter 中删除已弃用的选项

Streams API

KAFKA-12796

在 stream -scala 下删除已弃用的类

Streams API

KAFKA-12419

删除 3.0 中已弃用的 Kafka Streams API

Streams API

KAFKA-10434

删除 WindowStore 上已弃用的方法

Streams API

KAFKA-12449

删除已弃用的 WindowStore#put

Streams API

KAFKA-12813

删除 ProcessorContext 中已弃用的调度方法

Streams API

KAFKA-12809

删除 Stores 中已弃用的方法

Streams API

KAFKA-12814

删除已弃用的方法 StreamsConfig#getConsumerConfig

Streams API

KAFKA-12313

弃用 default.windowed.serde.inner.class 配置

Streams API

KAFKA-8372

删除已弃用的 RocksDB#compactRange API

Streams API

KAFKA-12584

删除已弃用的 SumTotal

Streams API

KAFKA-12683

删除已弃用的"UsePreviousTimeOnInvalidTimeStamp"

Streams API

KAFKA-12810

Remove deprecated TopologyDescription.Source#topics

Streams API

KAFKA-12630

Remove deprecated KafkaClientSupplier#getAdminClient

Streams API

KAFKA-10046

弃用的 PartitionGrouper 配置会被忽略

Streams API

KAFKA-12633

Remove deprecated "TopologyTestDriver#pipeInput / readOutput"

Streams API

KAFKA-12441

删除已弃用的方法 StreamsBuilder#addGlobalStore

Streams API

KAFKA-12452

为 ProcessorContext#forward 删除已弃用的过载

Streams API

KAFKA-12450

从 ReadOnlyWindowStore 中删除已弃用的方法

Streams API

KAFKA-12880

删除 3.0 中已弃用的 Count 和 SampledTotal

Streams API

KAFKA-12451

删除 WindowStore 中基于长期读取操作的弃用注解

Streams API

KAFKA-12568

删除已弃用的 "KStream#groupBy/join", "Joined#named" overloads

Streams API

KAFKA-12849

将 TaskMetadata 迁移到与内部实现的接口

Streams API

KAFKA-7785

删除 PartitionGrouper 接口及其配置,并将 DefaultPartitionGrouper 移到内部软件包

Streams API

KAFKA-7106

从窗口定义中删除片段/segmentInterval

Streams API

KAFKA-8897

增加 RocksDB 版本

Streams API

KAFKA-12909

允许用户选择-inbeious left/outer stream-stream 加入改进

工具

KAFKA-8405

删除已弃用的 kafka-preferred-replica-election 命令

工具

KAFKA-12588

删除 shell 命令中已弃用的 --zookeeper