# Metricbeat kafka output problem

**URL:** <https://discuss.elastic.co/t/metricbeat-kafka-output-problem/173287>\
**Category:** Beats\
**Tags:** metricbeat\
**Created:** [March 21, 2019, 10:21am UTC](https://discuss.elastic.co/t/metricbeat-kafka-output-problem/173287 "2019-03-21T10:21:22Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![khergner](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/khergner/32/130758_2.png) [@khergner](https://discuss.elastic.co/u/khergner)\
**Post date:** [March 21, 2019, 10:21am UTC](https://discuss.elastic.co/t/metricbeat-kafka-output-problem/173287/1 "2019-03-21T10:21:22Z")

</div>

Hi,  
I want to use message que for any beat. I search how to implemente message que in elastic system, I think we should use Kafka . I use metricbeat 6.6.1v so metricbeat data is send to kafka but Kafka can not log version. For example; metricbeat-6.6.1-2019-03-21, I had no problems use Beat--\> Logstash--\>ELK I create kafka topic

**metricbeat config**

```
#----------------------------- Kafka output --------------------------------
output.kafka:
  enabled: true
  hosts: ["172.28.26.169:9092"]  
  topic: '%{[type]}'
  partition.round_robin:
    reachable_only: false 
  required_acks: 1
  compression: none
  max_message_bytes: 1000000

```

**LOGSTASH Format**

```
input {
   kafka {
     bootstrap_servers => "172.28.26.169:9092"
     topics => ["%{[type]}"]
	 codec => "json"
  }
}
output {
  elasticsearch {
    hosts => ["172.28.26.169:9200"]
    index => "%{[type]}"
	workers => 1 }}

```

**Kafka Topic create**

`Topic name is metricbeat`

I don't know what to do if ı use filebeat. I was use Beat --\> Logstash old system and there is not problem. Beat data created dynamic method.  
I hope I can explain problem.  
Best regards.

---

<div class="post-metadata">

**Author:** ![ruflin](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/ruflin/32/3116_2.png) [@ruflin](https://discuss.elastic.co/u/ruflin)\
**Post date:** [March 29, 2019, 3:40pm UTC](https://discuss.elastic.co/t/metricbeat-kafka-output-problem/173287/2 "2019-03-29T15:40:09Z")

</div>

Not sure I can fully follow. What exaclty is now not working? You get some errors?

---

<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:** [April 26, 2019, 3:40pm UTC](https://discuss.elastic.co/t/metricbeat-kafka-output-problem/173287/3 "2019-04-26T15:40:25Z")

</div>

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