From 4a22b956206e64b389a99f0710d9f577d9e1f8a1 Mon Sep 17 00:00:00 2001 From: Leonard Sperry Date: Tue, 9 Jul 2024 09:16:14 -0400 Subject: [PATCH] Remove "unavailable" and "unknown" filters from Kafka integration (#121602) --- homeassistant/components/apache_kafka/__init__.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/homeassistant/components/apache_kafka/__init__.py b/homeassistant/components/apache_kafka/__init__.py index 8be70458a8f4fe..5d458262e28335 100644 --- a/homeassistant/components/apache_kafka/__init__.py +++ b/homeassistant/components/apache_kafka/__init__.py @@ -16,8 +16,6 @@ CONF_USERNAME, EVENT_HOMEASSISTANT_STOP, EVENT_STATE_CHANGED, - STATE_UNAVAILABLE, - STATE_UNKNOWN, ) from homeassistant.core import Event, EventStateChangedData, HomeAssistant import homeassistant.helpers.config_validation as cv @@ -121,7 +119,7 @@ def _encode_event(self, event: Event[EventStateChangedData]) -> bytes | None: state = event.data["new_state"] if ( state is None - or state.state in (STATE_UNKNOWN, "", STATE_UNAVAILABLE) + or state.state == "" or not self._entities_filter(state.entity_id) ): return None