lordgamez commented on a change in pull request #1120:
URL: https://github.com/apache/nifi-minifi-cpp/pull/1120#discussion_r681062674
##########
File path: docker/test/integration/minifi/core/SingleNodeDockerCluster.py
##########
@@ -225,21 +224,32 @@ def deploy_kafka_broker(self):
logging.info('Adding container \'%s\'', zookeeper.name)
self.containers[zookeeper.name] = zookeeper
+ def deploy_kafka_broker(self):
+ logging.info('Creating and running docker containers for kafka
broker...')
+ self.deploy_zookeeper()
+
test_dir = os.environ['PYTHONPATH'].split(':')[-1] # Based on
DockerVerify.sh
broker_image = self.build_image_by_path(test_dir +
"/resources/kafka_broker", 'minifi-kafka')
broker = self.client.containers.run(
broker_image[0],
detach=True,
name='kafka-broker',
network=self.network.name,
- ports={'9092/tcp': 9092, '29092/tcp': 29092},
+ ports={'9092/tcp': 9092, '29092/tcp': 29092, '9093/tcp': 9093,
'29093/tcp': 29093},
environment=[
"KAFKA_BROKER_ID=1",
- 'ALLOW_PLAINTEXT_LISTENER: "yes"',
-
"KAFKA_LISTENERS=PLAINTEXT://kafka-broker:9092,SSL://kafka-broker:9093,PLAINTEXT_HOST://0.0.0.0:29092",
-
"KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT,SSL:SSL",
-
"KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka-broker:9092,SSL://kafka-broker:9093,PLAINTEXT_HOST://localhost:29092",
- "KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181"])
+ "ALLOW_PLAINTEXT_LISTENER=yes",
+ "KAFKA_AUTO_CREATE_TOPICS_ENABLE=true",
+
"KAFKA_LISTENERS=PLAINTEXT://kafka-broker:9092,SSL://kafka-broker:9093,SSL_HOST://0.0.0.0:29093,PLAINTEXT_HOST://0.0.0.0:29092",
+
"KAFKA_LISTENER_SECURITY_PROTOCOL_MAP=PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT,SSL:SSL,SSL_HOST:SSL",
+ "KAFKA_SECURITY_INTER_BROKER_PROTOCOL=SSL",
+
"KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://kafka-broker:9092,PLAINTEXT_HOST://localhost:29092,SSL://kafka-broker:9093,SSL_HOST://localhost:29093",
+ "KAFKA_HEAP_OPTS=-Xms512m -Xmx1g",
+ "KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181",
+ "SSL_CLIENT_AUTH=none"],
+ volumes=self.vols,
+ sysctls={"net.ipv6.conf.all.disable_ipv6": "1"})
Review comment:
There was a theory that the ipv6 addresses cause networking problem in
docker, but that was disproved. I removed it in
af11b5fd586fe44f402e4704230aa3d01d29f838
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
