分享

Kafka2.2.0有哪些改变

pig2 2019-4-23 13:43:17 发表于 介绍解说 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 0 4411

问题导读

1.kafa支持了哪些验证?
2.API 做了什么改进?
3.Kafka2.2.0推荐哪个版本?

Kafka2.2.0我们来你看有哪些改变:

kafka为Scala的多个版本构建,建议使用2.12。

Kafka 2.2.0包含许多重要的新功能。 以下是一些值得注意的变化的摘要:
  • 添加了对自定义主体名称的SSL支持
  • 允许SASL连接定期重新进行身份验证
  • 命令行工具bin / kafka-topics.sh添加了AdminClient支持
  • 改进的使用者组管理:默认group.id为空而不是空字符串
  • Kafka Streams通过ThreadMetadata公开内部client.id.
  • 指标改进:所有-min,-avg和-max指标现在将输出NaN作为默认值


  • API 改进:

  • Producer:引入close(持续时间)
  • AdminClient:引入close(持续时间)
  • Kafka Streams:Streams DSL中的新flatTransform()运算符
  • KafkaStreams(以及其他类别)现在实现AutoClosable以支持try-with-resource
  • 新的Serdes和默认方法实现



更多信息可参考
https://www.apache.org/dist/kafka/2.2.0/RELEASE_NOTES.html

没找到任何评论,期待你打破沉寂

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条