Как изменить порт компонента «kafka connect»?

Question

На порту 8083 я использую Influxdb, для которого я даже получаю графический интерфейс на http://localhost:8083

Теперь перейдите к kafka, Здесь я ссылаюсь на настройку согласно https://kafka.apache.org/quickstart

запуск zookeeeper, который находится в папке /opt/zookeeper-3.4.10, с помощью команды: bin/zkServer.sh start

Таким образом, zookeeper теперь запускается, запуская kafka в папке /opt/kafka_2.11-1.1.0как:
bin/kafka-server-start.sh config/server.properties

создать тему с именем «test» с одним разделом и только одной репликой:
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

Тема создана и может быть проверена вс командой:
bin/kafka-topics.sh --list --zookeeper localhost:2181

Здесь все в порядке и настроено.

Теперь мне нужно использовать компонент " Kafka connect " для импорта / экспорта данных.,Поэтому я создаю начальные данные как: echo -e "foo\nbar" > test.txt

Теперь, используя конфигурацию соединителя для " kafka connect " для работы: bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties

после выполнения команды выше Iполучаю: Address already in use

Kafka connect has stopped

Я даже изменил rest.port=8084 в / opt/kafka_2.11-1.1.0/config/connect-distributed.properties, чтобы он не конфликтовал с influenxdb, который уже на 8083. Тем не менее я получаю те же Address already in use, Kafka connect has stopped, как показано на скриншотах.

Answer 1

Поскольку вы используете Kafka Connect в автономном режиме, вам нужно изменить порт REST в config/connect-standalone.properties:

rest.port=18083

Чтобы узнать больше о Standalone vs Distributed, вы можете прочитать документздесь .

Answer 2

Kafka Автономный режим, по умолчанию используется Port 8084 в качестве поста Rest API.По этой причине, если кто-то уже использует этот порт, процесс с помощью throw a BindException.

Чтобы изменить используемый выше порт, перейдите к файлу config/connect-standalone.properties в корневом каталоге Kafka.

Добавьте следующее свойство значения ключа, чтобы изменить порт, используемый для открытия Rest API.(Kafka должен был включить это в файл свойств по умолчанию, иначе многие разработчики сходят с ума, пытаясь найти сопоставление портов, используемое в автономном режиме).Поставьте другой порт по вашему желанию.

rest.port=11133

Answer 3

Изменение определения port в config / server.properties:

# The port the socket server listens on
port=9092