blob: 3c6d9dc17242a2d9c43d642025f03d6557f4dca1 (
plain)
1
2
3
4
5
6
7
8
|
local count = 0
function modify_kafka_message(tag, timestamp, record)
count = count + 1
local payload = record.payload
payload.topic = record.topic
payload.status = 'processed by fluent-bit, total records: '..tostring(count)
return 1, timestamp, payload
end
|