开发者社区> 问答> 正文

Flume的开发自定义组件中客户端的使用场景有哪些呢?

Flume的开发自定义组件中客户端的使用场景有哪些呢?

展开
收起
游客vqgchj4kfdzsu 2021-12-06 08:43:41 303 0
1 条回答
写回答
取消 提交回答
  • 第一种方法是创建自定义客户端,用来与Flume已有的Sources(比如AvroSource或是SyslogTcpSource)通信。自定义的客户端就需要将数据转换成能够被Flume这些Sources理解的消息。另一种方式是写一个自定义的Flume Source,能够直接与已存在的像使用了IPC或是RPC协议的应用程序通信,并将客户端的数据转换成Flume Events,然后推送到下游。请注意,要在Flume代理的Channel中存储的Events只能以Flume Events的格式存在。

    2021-12-06 11:23:11
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Apache Flink 流式应用中状态的数据结构定义升级 立即下载
Apache RocketMQ 云原生统一消息引擎 立即下载
为什么 Apache RocektMQ 是业务消息的首选 立即下载