В Kafka топики служат каналами для обмена сообщениями. Продюсеры публикуют сообщения в топики, а подписчики (консьюмеры) читают эти сообщения. Каждый топик разбит на партиции, что позволяет масштабировать обработку.

Подписчики могут быть организованы в группы консьюмеров. Каждое сообщение из партиции доставляется только одному консьюмеру в группе, что обеспечивает балансировку нагрузки. Обмен сообщениями происходит асинхронно: продюсер отправляет сообщение в топик, Kafka сохраняет его, а консьюмеры считывают по своему графику.

Пример на Java с использованием Kafka Consumer:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "my-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");

KafkaConsumer<String, String> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList("my-topic"));

while (true) {
    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
    for (ConsumerRecord<String, String> record : records) {
        System.out.printf("Received message: key = %s, value = %s, offset = %d\n", record.key(), record.value(), record.offset());
    }
}

Таким образом, топики и подписчики обеспечивают эффективный и масштабируемый обмен сообщениями в Kafka.

Каким образом топики в Kafka взаимодействуют с подписчиками и как осуществляется обмен сообщениями между ними?