Welcome to OGeek Q&A Community for programmer and developer-Open, Learning and Share
Welcome To Ask or Share your Answers For Others

Categories

0 votes
2.0k views
in Technique[技术] by (71.8m points)

logstash - One extra event per file

I use logstash in order to process *.csv files and push them to kafka topic. Following plugins used:

  • logstash-integration-kafka
  • logstash-codec-csv

Input file has format (2 fields with separator, no heading):

1234556;fraud
2342342;collection
... 0-250k records ...

But now apart from pushing of the content of the file I have to emit one extra event in the beginning of each file processing and then push it to kafka as well (same or different topic - doesn't matter).

All I managed to thought out is a separate pipeline with multiline codec that will treat a csv file as an event.

Is there any good solution for this?


与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
Welcome To Ask or Share your Answers For Others

1 Reply

0 votes
by (71.8m points)
等待大神答复

与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…
OGeek|极客中国-欢迎来到极客的世界,一个免费开放的程序员编程交流平台!开放,进步,分享!让技术改变生活,让极客改变未来! Welcome to OGeek Q&A Community for programmer and developer-Open, Learning and Share
Click Here to Ask a Question

1.4m articles

1.4m replys

5 comments

57.0k users

...