Где и как topi c создается в брокере, когда дается скрипт с подробной информацией о количестве разделов и коэффициенте реплики

Question

, когда мы создаем топи c, где мы определяем количество разделов и коэффициент реплики. Это topi c создается во всех брокерах? Это указано c для какого-либо одного брокера?

Answer 1

Вы можете создать topi c с помощью этой команды:

./bin/kafka-topics.sh --create --zookeeper <ZOOKEEPER_URL:PORT> --replication-factor <NO_OF_REPLICATIONS> --partitions <NO_OF_PARTITIONS> --topic <TOPIC_NAME>

После этой команды метаданные о topi c (количество разделов, реплик, список ISR и т. Д. c.) хранится в Zookeeper. Вы можете получить информацию о topi c с помощью этой команды:

./bin/kafka-topics.sh --zookeeper localhost:2181 --topic TopicName --describe

Список разделов реплики создается в соответствии с алгоритмом циклического перебора, а брокер-контролер отвечает за уведомление о создании новых topi c и запуск разделов назначение.

Answer 2

При создании тем вы обязаны передавать фактор репликации и разделы.

Выбор брокера (-ов) каждого раздела и реплики определяется случайным образом, хотя позже вы можете использовать kafka-reassign-partitions для перемещения реплик другим брокерам.