Apache Kafka 2.6.0 是 Kafka 的最新版本,随着这个版本的发布,Kafka 又有了一些值得关注的变化。下面是一些值得关心的变化:
- 支持KIP-595——为消息加上元数据属性(Header)
Kafka 2.6.0 引入了 KIP-595,提供了向Kafka消息添加元数据属性(Header)的支持。添加元数据属性非常有用,可以存储一些额外信息(例如,消息的来源、许可证、拥有者等等)。元数据属性还可以用于消息过滤和路由(例如,您使用Header中的属性控制消息转发到哪个地区或目标)。
- 支持 KIP-586——Kafka 没有状态流构造器
Kafka 2.6.0 引入了 KIP-586,使 Kafka Streams 可以使用没有状态的构造器,在这种情况下,Kafka 会自动创建一个局部状态存储。
使用没有状态的构造器,可以更容易地编写和调试流处理器,并改善性能和可伸缩性。
- 增强了 Kafka Connect 管理 API
Kafka 2.6.0 改进了 Kafka Connect 管理 API,提供了更好的管理 Kafka Connect 连接器和任务的方法。以前,API 能够获取有关连接器和任务的信息,但却不能对它们进行操作。现在,管理 API 允许用户操作连接器和任务,并提供了一些新的端点,例如重置 Offset、暂停和恢复任务等。
- 支持 KIP-595——在 Kafka 命令行工具中使用元数据属性
Kafka 2.6.0 引入了 KIP-595,可以在命令行工具中使用元数据属性(Header)。这意味着用户可以更方便地使用 Kafka 命令行工具来控制消息的元数据,而无需编写 Kafka 客户端。
- 增强了 KRaft 副本管理器
Kafka 2.6.0 进一步增强了 KRaft 副本管理器,提供了更好的容错能力。Kafka 使用 KRaft replicator 提供复制机制,以保证 Kafka 的数据的持久化和高可靠性,Kafka 2.6.0 版本增强了这一模块的性能和可靠性。
- 支持 KIP-559——Kafka Manager 客户端支持
Kafka 2.6.0 引入了 KIP-559,提供了 Kafka Manager 客户端的支持。Kafka Manager 客户端是一款管理 Kafka 集群的 Web 应用程序,使用户可以更方便地从 Web 界面查看和管理 Kafka 集群的状态,包括监视 topic、分区和消费者,查看主题消息,修改分区分配等等。
总的来说,Apache Kafka 2.6.0 的变化使得 Kafka 更加易于使用和管理,同时也提高了其可靠性和性能。这些变化将有助于 Kafka 用户更好地处理大量的消息并提高生产力。