kafka source type

Posted rsapaper

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafka source type相关的知识,希望对你有一定的参考价值。

 

https://flume.apache.org/FlumeUserGuide.html

 

# example.conf: A single-node Flume configuration

# Name the components on this agent
a1.sources = r1
a1.sinks = k1
a1.channels = c1
 

 

【测试模拟】

a1.sources.r1.type = exec

a1.sources.r1.command = tail -F /opt/data/access.log

 

【生产】


# Describe/configure the source a1.sources.r1.type = netcat a1.sources.r1.bind = localhost a1.sources.r1.port = 44444


 

以上是关于kafka source type的主要内容,如果未能解决你的问题,请参考以下文章

flume对接kafka

Flume自定义分区实现kafka有序

flume从kafka中读取数据

使用kafka作为生产者生产数据到hdfs

flume:spooldir采集日志,kafka输出的配置问题

使用kafka作为生产者生产数据到hdfs(单节点)