Я новичок в мире kafka и пытаюсь сделать следующее для потребителя kafka в python
Примечание. Для этого я могу использовать либо библиотеку confluent-kafka / kafka-python.
Любая помощь будет оценена.
если вы создали своего потребителя с kafka-python
from kafka import KafkaConsumer
consumer = KafkaConsumer(
bootstrap_servers = 'hostname:port',
)
вы можете просмотреть список тем, доступных с помощью
consumer.topics()
когда вы подписываетесь на темы, вы можете просматривать подписки потребителей с помощью
consumer.subscription()
Вы можете сделать одно минус другое, чтобы найти темы, на которые вам все еще нужно подписаться, а затем вы можете сделать это с помощью
consumer.subscribe(topics=[list_of_topic_names])
