[FLUME-3272] A lot of repetitions occurred when sending messages using kafkaSink - ASF JIRA

XML

Word

Printable

JSON

Docs Text:

Hide
I added a piece of logic to KafkaSink's process() method. The main effect is to get a valid event, get the body from it, make some changes, and then set the event.Then I packaged it and passed it to the server.
But after going online, kafka received a large number of duplicate messages from the flume.
I really don't know what it caused, so I would like to ask you why, thank you!

Show
I added a piece of logic to KafkaSink's process() method. The main effect is to get a valid event, get the body from it, make some changes, and then set the event.Then I packaged it and passed it to the server. But after going online, kafka received a large number of duplicate messages from the flume. I really don't know what it caused, so I would like to ask you why, thank you!