微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Kafka Spout SSL 风暴

如何解决Kafka Spout SSL 风暴

我们有一个类型学,我们从 Kafka 收集流量并将其发送到 Storm 以实时处理数据。

我们配置了一个 Kafka 生产者,使用带有证书的 SSL 发送流量。然后在 Kafka 服务器中接收流量,并且需要由 Apache Storm 使用 Kafka spout 访问。

关于 Storm 上的配置以及在 Kafka spout 中读取来自 Kafka 的加密流量的类型学有什么帮助吗?

我们确实尝试过:https://github.com/apache/storm/tree/master/external/storm-kafka-client,但是我们无法在执行时在 spout 上没有错误的情况下将流量获取到 Storm。

我们正在使用以下版本:

  • 风暴 1.1.0
  • 卡夫卡 0.10.1
  • HDP-2.6.4.0

谢谢

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。