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