apache-kafka - Apache Kafka 沿袭信息
问题描述
有什么方法可以获取Kafka作业的沿袭数据。
例如,我们有一个用于所有MapReduce作业的Job History URL。
Kafka 是否有类似的东西,我可以在其中获取生产者的元数据,从而为特定主题生成信息?(例如:生产者的 IP 地址)
解决方案
开箱即用,不,不适用于制片人。
您可以列出消费者客户端地址,但不能将生产者纳入主题。
一种选择是查看 Apache Atlas 以获取沿袭信息,这是 Hortonwork 的Stream Messaging Manager的一个组件,用于分析 Kafka 连接信息。
否则,您将无法让生产者将这些数据与消息一起发送。
推荐阅读
- .net-core - 未创建 Serilog 和 .NET Core Web API 日志文件
- groovy - 如果一步成功,如何在并行构建中设置条件以进行下一阶段
- python - 将一个嵌套字典的值更新到另一个具有字典列表的字典
- python - 如何将 django 抽象类与 graphene-django 一起使用?
- c# - 如何从导航列表中删除页面并终止该页面的所有进程?
- sybase - Sybase:如何显示当前会话变量的值?
- python - python socket pickled numpy 数据没有显示
- c# - IIS 上的 WCF 路由服务
- swift - SwiftUI Navigation:如何将详细视图切换到不同的项目?
- sql - 将行号添加到存储过程