Что такое Apache Kafka

Apache Kafka — это распределённая потоковая платформа для обработки событий в реальном времени. Она работает как брокер сообщений, обеспечивая высокую пропускную способность, отказоустойчивость и горизонтальную масштабируемость.

Основные компоненты:

• Топики (Topics) — логические каналы для сообщений.
• Партиции (Partitions) — части топика для параллельной обработки.
• Producer — отправляет сообщения в топик.
• Consumer — читает сообщения из топика.
• Broker — сервер Kafka, хранящий данные.

Пример Producer на Java:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Producer<String, String> producer = new KafkaProducer<>(props);
producer.send(new ProducerRecord<>("my_topic", "key", "value"));
producer.close();

Используется для логов, аналитики, микросервисов и event-driven архитектур.