diff --git a/mapper.go b/mapper.go index 87252ec..f23fdb9 100644 --- a/mapper.go +++ b/mapper.go @@ -13,9 +13,8 @@ func DefaultMapper(event couchbase.Event) []message.KafkaMessage { } return []message.KafkaMessage{ { - Headers: nil, - Key: event.Key, - Value: event.Value, + Key: event.Key, + Value: event.Value, }, } }