home-assistant.io/source/_integrations/apache_kafka.markdown
joris1989 eb46dab220
Host parameter should be named ip_address (#13032)
The extension does not work with the 'host' :
Invalid config for [apache_kafka]: [host] is an invalid option for [apache_kafka]. Check: apache_kafka->apache_kafka->host. (See /home/joris/.homeassistant/configuration.yaml, line 18). Please check the docs at https://www.home-assistant.io/integrations/apache_kafka. 

Looking at the code it should be 'ip_address'. Tested and works. 
As this is my first PR, maybe a better solution would be to change the code to use host instead of ip_address. I could not find any documentation about this and this fix is less errorprone than changing the code.
2020-04-17 15:44:23 +02:00

1.5 KiB

title, description, ha_category, ha_release, ha_codeowners, ha_domain
title description ha_category ha_release ha_codeowners ha_domain
Apache Kafka Send data and events to Apache Kafka.
History
0.97
@bachya
apache_kafka

The apache_kafka integration sends all state changes to a Apache Kafka topic.

Apache Kafka is a real-time data pipeline that can read and write streams of data. It stores its data safely in a distributed, replicated, fault-tolerant cluster.

To use the apache_kafka integration in your installation, add the following to your configuration.yaml file:

apache_kafka:
  ip_address: localhost
  port: 9092
  topic: home_assistant_1

{% configuration %} ip_address: description: The IP address or hostname of an Apache Kafka cluster. required: true type: string port: description: The port to use. required: true type: integer topic: description: The Kafka topic to send data to. required: true type: string filter: description: Filters for entities to be included/excluded. required: false type: map keys: include_domains: description: Domains to be included. required: false type: list include_entities: description: Entities to be included. required: false type: list exclude_domains: description: Domains to be excluded. required: false type: list exclude_entities: description: Entities to be excluded. required: false type: list {% endconfiguration %}