Я соединяю производителя и потребителя kafka, предоставляя порт IP kafka broker.Как я могу проверить, успешно ли подключен брокер?