Feat: add ignoreUnknownTopicOrPartition in kafka sink

loggie-io / loggie

A lightweight, cloud-native data transfer agent and aggregator

https://loggie-io.github.io/docs-en/

Apache License 2.0

1.26k stars 167 forks source link

Closed ethfoo closed 1 year ago

ethfoo commented 1 year ago

sink:
  type: kafka
  brokers: ["127.0.0.1:6400"]
  topic: "log-${fields.topic}"
  ignoreUnknownTopicOrPartition: true

if ignoreUnknownTopicOrPartition: true, ignore error when kafka topic or partion not exsit.