fluent-bit/examples/kafka_filter/kafka.lua


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