# Filebeat log gets flooded if no Kafka topic is available

**URL:** <https://discuss.elastic.co/t/filebeat-log-gets-flooded-if-no-kafka-topic-is-available/314702>\
**Category:** Beats\
**Tags:** filebeat\
**Created:** [September 19, 2022, 2:17pm UTC](https://discuss.elastic.co/t/filebeat-log-gets-flooded-if-no-kafka-topic-is-available/314702 "2022-09-19T14:17:42Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![YvorL](https://avatars.discourse-cdn.com/v4/letter/y/9fc348/32.png) [@YvorL](https://discuss.elastic.co/u/YvorL)\
**Post date:** [September 19, 2022, 2:17pm UTC](https://discuss.elastic.co/t/filebeat-log-gets-flooded-if-no-kafka-topic-is-available/314702/1 "2022-09-19T14:17:42Z")

</div>

Hi,

I have an issue where Filebeat tries to send data to a Kafka topic that doesn't exist anymore. The Filebeat logs are flooded with:

```auto
2022-09-19T13:47:29.111Z INFO [publisher] pipeline/retry.go:223 done
2022-09-19T13:47:29.111Z INFO [publisher] pipeline/retry.go:219 retryer: send unwait signal to consumer
2022-09-19T13:47:29.111Z INFO [publisher] pipeline/retry.go:223 done
2022-09-19T13:47:29.112Z INFO [publisher] pipeline/retry.go:219 retryer: send unwait signal to consumer
2022-09-19T13:47:29.112Z INFO [publisher] pipeline/retry.go:223 done
2022-09-19T13:47:29.112Z INFO [publisher] pipeline/retry.go:219 retryer: send unwait signal to consumer
2022-09-19T13:47:29.112Z INFO [publisher] pipeline/retry.go:223 done

```

Filebeat writes 16 lines per millisecond to the logs and rotates out every useful info in a blink of an eye. My FB configuration is:

```auto
  hosts: ["...", "...", "..."]

  topic: "default_topic"
  topics:
    - topic: '%{[topic_name]}'
      when.has_fields: ['topic_name']

  partition.round_robin:
    reachable_only: true

  ssl.certificate_authorities: ["..."]
  username: "..."
  password: "..."

  required_acks: -1
  compression: snappy

```

Is there a way to prevent this behavior? Unfortunately, it doesn't fall back to the "topic" due to the infinite loop.

Thanks!

Filebeat version: 7.9.2  
Kafka version: 3.2.1

---

<div class="post-metadata">

**Author:** ![YvorL](https://avatars.discourse-cdn.com/v4/letter/y/9fc348/32.png) [@YvorL](https://discuss.elastic.co/u/YvorL)\
**Post date:** [September 23, 2022, 5:14pm UTC](https://discuss.elastic.co/t/filebeat-log-gets-flooded-if-no-kafka-topic-is-available/314702/2 "2022-09-23T17:14:42Z")

</div>

Should I raise this question on GitHub?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [October 21, 2022, 7:15pm UTC](https://discuss.elastic.co/t/filebeat-log-gets-flooded-if-no-kafka-topic-is-available/314702/3 "2022-10-21T19:15:38Z")

</div>

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.