From a94c27fd5cb35cfa24ecaa75fe9f1adf0689844c Mon Sep 17 00:00:00 2001 From: kubotat Date: Wed, 11 Oct 2023 17:55:55 +0000 Subject: [PATCH] update README.md Signed-off-by: kubotat --- README.md | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/README.md b/README.md index ae336c2..e4ad29d 100644 --- a/README.md +++ b/README.md @@ -517,6 +517,7 @@ You need to install rdkafka gem. exclude_topic_key (bool) :default => false exclude_partition_key (bool) :default => false discard_kafka_delivery_failed (bool) :default => false (No discard) + discard_kafka_delivery_failed_regex (regexp) :default => nil (No discard) use_event_time (bool) :default => false # same with kafka2 @@ -559,6 +560,9 @@ You need to install rdkafka gem. max_enqueue_bytes_per_second (integer) :default => nil +`rdkafka2` supports `discard_kafka_delivery_failed_regex` parameter: +- `discard_kafka_delivery_failed_regex` - default: nil - discard the record where the Kafka::DeliveryFailed occurred and the emitted message matches the given regex pattern, such as `/unknown_topic/`. + If you use v0.12, use `rdkafka` instead.