# Send data from filebeat to kafka(with kerberos) failed

**URL:** <https://discuss.elastic.co/t/send-data-from-filebeat-to-kafka-with-kerberos-failed/284479>\
**Category:** Beats\
**Tags:** filebeat\
**Created:** [September 17, 2021, 11:47am UTC](https://discuss.elastic.co/t/send-data-from-filebeat-to-kafka-with-kerberos-failed/284479 "2021-09-17T11:47:37Z")\
**Posts on this page:** 2\
**Page:** 1

<div class="post-metadata">

**Author:** ![charlielin](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/charlielin/32/94718_2.png) [@charlielin](https://discuss.elastic.co/u/charlielin)\
**Post date:** [September 17, 2021, 11:47am UTC](https://discuss.elastic.co/t/send-data-from-filebeat-to-kafka-with-kerberos-failed/284479/1 "2021-09-17T11:47:37Z")

</div>

filebeat: filebeat-7.10.2-linux-x86\_64  
kafka: kafka\_2.13-2.6.0/

here is my filebeat config:

```auto
filebeat.inputs:
- type: log

  # Change to true to enable this input configuration.
  enabled: true
  fields_under_root: true

  # Paths that should be crawled and fetched. Glob based paths.
  paths:
    - /home/work/test/log/*.log
    #- c:\programdata\elasticsearch\logs\*
  json.keys_under_root: true
  json.add_error_key: false
  json.overwrote_keys: true
output.kafka:
  enabled: true
  hosts: ["xxx1:9093",
          "xxx2:9093"]
  topic: "test3"
  partition.round_robin:
    reachable_only: false
  compression: none
  max_message_bytes: 1000000
  sasl.mechanism:
  kerberos.enabled: true
  kerberos.auth_type: keytab
  kerberos.username: "yuenxu"
  kerberos.keytab: "/home/work/keytab/yuenxu.keytab"
  kerberos.service_name: "kafka"
  kerberos.config_path: "/home/work/krb5/krb5.conf"
  kerberos.realm: "LZ.DSCC.99.COM"

```

About the kafka with kerberos, I have test it with console producer/consumer. It's OK.

Here is the filebeat error message:

```auto
2021-09-17T19:31:19.916+0800	INFO	[publisher]	pipeline/retry.go:219	retryer: send unwait signal to consumer
2021-09-17T19:31:19.916+0800	INFO	[publisher]	pipeline/retry.go:223 done
2021-09-17T19:31:19.996+0800	DEBUG	[kafka]	kafka/client.go:277	finished kafka batch
2021-09-17T19:31:19.996+0800	DEBUG	[kafka]	kafka/client.go:291	Kafka publish failed with: circuit breaker is open
2021-09-17T19:31:19.996+0800	INFO	[publisher]	pipeline/retry.go:219	retryer: send unwait signal to consumer
2021-09-17T19:31:19.996+0800	INFO	[publisher]	pipeline/retry.go:223 done

```

Is there anything wrong? Thanks.

---

<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 15, 2021, 1:48pm UTC](https://discuss.elastic.co/t/send-data-from-filebeat-to-kafka-with-kerberos-failed/284479/2 "2021-10-15T13:48:28Z")

</div>

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