# Kafka metricbeat config

**URL:** <https://discuss.elastic.co/t/kafka-metricbeat-config/144679>\
**Category:** Beats\
**Tags:** metricbeat\
**Created:** [August 16, 2018, 9:45am UTC](https://discuss.elastic.co/t/kafka-metricbeat-config/144679 "2018-08-16T09:45:21Z")\
**Posts on this page:** 4\
**Page:** 1

<div class="post-metadata">

**Author:** ![InspurKelly](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/inspurkelly/32/90931_2.png) [@InspurKelly](https://discuss.elastic.co/u/InspurKelly)\
**Post date:** [August 16, 2018, 9:45am UTC](https://discuss.elastic.co/t/kafka-metricbeat-config/144679/1 "2018-08-16T09:45:21Z")

</div>

Hi,  
I use metricbeat collecting kafka metrics, i want to filter data when kafka.partition.partition.leader not equals kafka.partition.partition.replica,

metricbeat.modules:

module: kafka  
name: "kafka"  
metricsets: ["consumergroup", "partition"]  
period: 10s  
hosts: ["\*\*\*\*\*\*\*\*"]  
enabled: true  
processors:  
drop\_event.when.not.equals:  
kafka.partition.partition.leader: kafka.partition.partition.replica

How do I configure it?

---

<div class="post-metadata">

**Author:** ![jsoriano](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/jsoriano/32/27920_2.png) [@jsoriano](https://discuss.elastic.co/u/jsoriano)\
**Post date:** [August 16, 2018, 1:14pm UTC](https://discuss.elastic.co/t/kafka-metricbeat-config/144679/2 "2018-08-16T13:14:49Z")

</div>

Hi @InspurKelly and welcome 🙂

It is not possible to use fields as values for conditions.  
For your case I guess that you want to drop events if they are not from leader partitions, in that case you may find useful a new field [`kafka.partition.partition.is_leader`](https://github.com/elastic/beats/pull/7767/files#diff-d43087d796b8b1d1ff48ec3561aeda60R7247) that we have added and will be available in 6.5.

---

<div class="post-metadata">

**Author:** ![InspurKelly](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/inspurkelly/32/90931_2.png) [@InspurKelly](https://discuss.elastic.co/u/InspurKelly)\
**Post date:** [August 17, 2018, 12:51am UTC](https://discuss.elastic.co/t/kafka-metricbeat-config/144679/3 "2018-08-17T00:51:31Z")

</div>

ok,Thanks for your reply

---

<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:** [September 14, 2018, 12:51am UTC](https://discuss.elastic.co/t/kafka-metricbeat-config/144679/4 "2018-09-14T00:51:32Z")

</div>

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