Какой опыт работы с Kafka

Работал с Apache Kafka в нескольких проектах, в основном для обработки потоковых данных и событий. Использовал kafka-python и confluent-kafka для producer/consumer логики.

Пример producer:

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers='localhost:9092')
producer.send('test-topic', b'Hello, Kafka!')
producer.flush()

Пример consumer:

from kafka import KafkaConsumer

consumer = KafkaConsumer('test-topic', bootstrap_servers='localhost:9092')
for msg in consumer:
    print(msg.value.decode('utf-8'))

Также работал с:

• Настройкой топиков (партиции, репликация)
• Обработкой ошибок (retry, dead-letter queues)
• Интеграцией Kafka с другими сервисами (Django, FastAPI)
• Мониторингом через Prometheus + Grafana

Глубоко не настраивал кластер, но понимаю архитектуру (brokers, zookeeper, ISR).