kafka+flume+kafka中问题.pdf
flume从kafka读取数据,然后再sink到kafka中,
这种场景下会出现问题。
(1)现象表示为:
flume从kafka读取数据,sink的sinkTopic中没有数据,也无法从sinkTopic中读取数据;
(2)原因分析:
如果在一个FlumeAgent中同时使用KafkaSource和KafkaSink来处理events,便会遇到KafkaTopic覆盖问题,具体
表现为,KafkaSource可以正常从指定的Topic中读取数据,但在KafkaSink中配置的目标Topic不起作用,数据仍然
会被写入到Source中指定的Topic中。
暂无评论