Skip to content

Commit 667fee6

Browse files
author
Petr Šebek
committed
change_subscription warning log to info
When we are using subscription by pattern change subscription is called every metadata update even when nothing changes. It logs warning every time topics are not changed.
1 parent b8da199 commit 667fee6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

kafka/consumer/subscription_state.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -137,8 +137,8 @@ def change_subscription(self, topics):
137137
topics = [topics]
138138

139139
if self.subscription == set(topics):
140-
log.warning("subscription unchanged by change_subscription(%s)",
141-
topics)
140+
log.info("subscription unchanged by change_subscription(%s)",
141+
topics)
142142
return
143143

144144
if any(not isinstance(t, six.string_types) for t in topics):

0 commit comments

Comments
 (0)