Где находится топик в Kafka

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

Пример создания топика через AdminClient:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
AdminClient admin = AdminClient.create(props);

NewTopic newTopic = new NewTopic("my-topic", 3, (short) 2);
admin.createTopics(Collections.singleton(newTopic));
admin.close();

Где:
- `my-topic` - имя топика
- `3` - количество партиций
- `2` - фактор репликации

Топики хранятся в файловой системе брокера в директории, указанной в `log.dirs` конфигурации Kafka.