{"action":"closed","issue":{"url":"https://api.github.com/repos/wurstmeister/kafka-docker/issues/265","repository_url":"https://api.github.com/repos/wurstmeister/kafka-docker","labels_url":"https://api.github.com/repos/wurstmeister/kafka-docker/issues/265/labels{/name}","comments_url":"https://api.github.com/repos/wurstmeister/kafka-docker/issues/265/comments","events_url":"https://api.github.com/repos/wurstmeister/kafka-docker/issues/265/events","html_url":"https://github.com/wurstmeister/kafka-docker/issues/265","id":296189733,"number":265,"title":" Error creating broker listeners from 'PLAINTEXT://:tcp://10.99.149.156:9092': No security protocol defined for listener PLAINTEXT://:TCP","user":{"login":"wvxvw-traiana","id":33873667,"avatar_url":"https://avatars0.githubusercontent.com/u/33873667?v=4","gravatar_id":"","url":"https://api.github.com/users/wvxvw-traiana","html_url":"https://github.com/wvxvw-traiana","followers_url":"https://api.github.com/users/wvxvw-traiana/followers","following_url":"https://api.github.com/users/wvxvw-traiana/following{/other_user}","gists_url":"https://api.github.com/users/wvxvw-traiana/gists{/gist_id}","starred_url":"https://api.github.com/users/wvxvw-traiana/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/wvxvw-traiana/subscriptions","organizations_url":"https://api.github.com/users/wvxvw-traiana/orgs","repos_url":"https://api.github.com/users/wvxvw-traiana/repos","events_url":"https://api.github.com/users/wvxvw-traiana/events{/privacy}","received_events_url":"https://api.github.com/users/wvxvw-traiana/received_events","type":"User","site_admin":false},"labels":[{"id":71948331,"url":"https://api.github.com/repos/wurstmeister/kafka-docker/labels/duplicate","name":"duplicate","color":"cccccc","default":true},{"id":864353276,"url":"https://api.github.com/repos/wurstmeister/kafka-docker/labels/kubernetes","name":"kubernetes","color":"ef9a32","default":false},{"id":71948334,"url":"https://api.github.com/repos/wurstmeister/kafka-docker/labels/question","name":"question","color":"cc317c","default":true}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":3,"created_at":"2018-02-11T13:24:03Z","updated_at":"2018-03-29T08:02:51Z","closed_at":"2018-03-29T08:02:51Z","author_association":"NONE","body":"This must be caused by misconfiguration of something, but I don't know this project well enough to say what was misconfigured.  This line looks suspicious: https://github.com/wurstmeister/kafka-docker/blob/master/start-kafka.sh#L82 but I could be wrong.\r\n\r\nIn any case, with all defaults this image should produce some sensible configuration in which it can run or report an error that is understandable by human beings.  The error above comes from lack of validation of default parameters of this image.\r\n\r\nI've added `set -x` to `start-kafka.sh`.  Below is the output I get:\r\n\r\n```\r\n./start-kafka.sh\r\n+ [[ -z tcp://10.111.134.92:9092 ]]\r\n+ + [[ -z create-topics.sh''\r\n ]]\r\n+ [[ -z '' ]]\r\n+ [[ -z '' ]]\r\n+ [[ -S /var/run/docker.sock ]]\r\n+ [[ -z '' ]]\r\n+ [[ -n '' ]]\r\n+ export KAFKA_BROKER_ID=-1\r\n+ KAFKA_BROKER_ID=-1\r\n+ [[ -z '' ]]\r\n+ export KAFKA_LOG_DIRS=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz\r\n+ KAFKA_LOG_DIRS=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz\r\n+ [[ -z 127.0.0.1:2181 ]]\r\n+ [[ -n '' ]]\r\n+ [[ -z 127.0.0.1 ]]\r\n+ [[ -n '' ]]\r\n+ export KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092\r\n+ KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092\r\n+ export KAFKA_LISTENERS=PLAINTEXT://:tcp://10.111.134.92:9092\r\n+ KAFKA_LISTENERS=PLAINTEXT://:tcp://10.111.134.92:9092\r\n+ [[ -n '' ]]\r\n+ [[ -n '' ]]\r\n+ [[ -n '' ]]\r\n+ [[ -n '' ]]\r\n+ [[ -n '' ]]\r\n+ [[ -n '' ]]\r\n+ echo -e '\\n'\r\n+ unset KAFKA_CREATE_TOPICS\r\n+ unset KAFKA_ADVERTISED_PROTOCOL_NAME\r\n+ unset KAFKA_PROTOCOL_NAME\r\n+ [[ -n PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092 ]]\r\n+ unset KAFKA_ADVERTISED_PORT\r\n+ unset KAFKA_ADVERTISED_HOST_NAME\r\n+ [[ -n PLAINTEXT://:tcp://10.111.134.92:9092 ]]\r\n+ unset KAFKA_PORT\r\n+ unset KAFKA_HOST_NAME\r\n++ env\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP=tcp://10.110.124.218:4000 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP=tcp://10.110.124.218:4000 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JAVA_VERSION_BUILD=16 =~ ^KAFKA_ ]]\r\n+ [[ JAVA_VERSION_BUILD=16 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_HOME=/opt/kafka =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_HOME=/opt/kafka =~ ^KAFKA_HOME ]]\r\n+ [[ KAFKA_HOME=/opt/kafka =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP_ADDR=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP_ADDR=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP=tcp://10.97.94.81:4102 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP=tcp://10.97.94.81:4102 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP=tcp://10.98.201.219:4103 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP=tcp://10.98.201.219:4103 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ HOSTNAME=kafka-6d5ff44f6c-hqrtz =~ ^KAFKA_ ]]\r\n+ [[ HOSTNAME=kafka-6d5ff44f6c-hqrtz =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP_PORT=4142 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP_PORT=4142 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP=tcp://10.97.94.81:4002 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP=tcp://10.97.94.81:4002 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_PORT=tcp://10.110.72.37:2181 =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_PORT=tcp://10.110.72.37:2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_PORT_9042_TCP_PORT=9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_PORT_9042_TCP_PORT=9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP_PORT=5150 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP_PORT=5150 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP_ADDR=10.110.124.218 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP_ADDR=10.110.124.218 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_9092_TCP_PORT=9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_9092_TCP_PORT=9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_9092_TCP_PORT=9092\r\n++ tr _ .\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n+ kafka_name=port.9092.tcp.port\r\n++ echo KAFKA_PORT_9092_TCP_PORT=9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_9092_TCP_PORT\r\n+ egrep -q '(^|^#)port.9092.tcp.port=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.9092.tcp.port)=(.*)@\\2=9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_9092_TCP_PORT=9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_PORT_PORT_2=2181 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_PORT_PORT_2=2181 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_PORT_PORT_2=2181\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' ++ '[:lower:]'\r\ntr _ .\r\n+ kafka_name=service.port.port.2\r\n++ echo KAFKA_SERVICE_PORT_PORT_2=2181\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_PORT_PORT_2\r\n+ egrep -q '(^|^#)service.port.port.2=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.port.port.2)=(.*)@\\2=2181@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_PORT_PORT_2=2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP_ADDR=10.110.185.158 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_PORT_9092_TCP_ADDR=10.110.185.158 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP_ADDR=10.110.185.158\r\n++ tr _ .\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n+ kafka_name=service.port.9092.tcp.addr\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP_ADDR=10.110.185.158\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_PORT_9092_TCP_ADDR\r\n+ egrep -q '(^|^#)service.port.9092.tcp.addr=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.port.9092.tcp.addr)=(.*)@\\2=10.110.185.158@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP_ADDR=10.110.185.158 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_2181_TCP_PORT=2181 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_2181_TCP_PORT=2181 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_2181_TCP_PORT=2181\r\n++ ++ tr '[:upper:]' '[:lower:]'\r\nsed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr _ .\r\n+ kafka_name=port.2181.tcp.port\r\n++ echo KAFKA_PORT_2181_TCP_PORT=2181\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_2181_TCP_PORT\r\n+ egrep -q '(^|^#)port.2181.tcp.port=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.2181.tcp.port)=(.*)@\\2=2181@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_2181_TCP_PORT=2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ TERM=xterm =~ ^KAFKA_ ]]\r\n+ [[ TERM=xterm =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_ZOOKEEPER_CONNECT=127.0.0.1:2181 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_ZOOKEEPER_CONNECT=127.0.0.1:2181 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_ZOOKEEPER_CONNECT=127.0.0.1:2181\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ tr _ .\r\n+ kafka_name=zookeeper.connect\r\n++ echo KAFKA_ZOOKEEPER_CONNECT=127.0.0.1:2181\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_ZOOKEEPER_CONNECT\r\n+ egrep -q '(^|^#)zookeeper.connect=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(zookeeper.connect)=(.*)@\\2=127.0.0.1:2181@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_ZOOKEEPER_CONNECT=127.0.0.1:2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_PORT_PORT_1=9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_PORT_PORT_1=9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_PORT_PORT_1=9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr _ .\r\ntr '[:upper:]' '[:lower:]'\r\n+ kafka_name=service.port.port.1\r\n++ echo KAFKA_SERVICE_PORT_PORT_1=9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_PORT_PORT_1\r\n+ egrep -q '(^|^#)service.port.port.1=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.port.port.1)=(.*)@\\2=9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_PORT_PORT_1=9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_PORT_443_TCP_PORT=443 =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_PORT_443_TCP_PORT=443 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_PORT=tcp://10.96.0.1:443 =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_PORT=tcp://10.96.0.1:443 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_PORT_9092_TCP_PROTO=tcp =~ ^KAFKA_HOME ]]\r\n++ ++ tr _ .\r\nsed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP_PROTO=tcp\r\n+ kafka_name=service.port.9092.tcp.proto\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP_PROTO=tcp\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_PORT_9092_TCP_PROTO\r\n+ egrep -q '(^|^#)service.port.9092.tcp.proto=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.port.9092.tcp.proto)=(.*)@\\2=tcp@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT=tcp://10.96.217.66:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT=tcp://10.96.217.66:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JAVA_VERSION_MAJOR=8 =~ ^KAFKA_ ]]\r\n+ [[ JAVA_VERSION_MAJOR=8 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ SCALA_VERSION=2.12 =~ ^KAFKA_ ]]\r\n+ [[ SCALA_VERSION=2.12 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP_ADDR=10.109.255.57 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP_ADDR=10.109.255.57 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_HOST=10.109.255.57 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_HOST=10.109.255.57 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP_PORT=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP_PORT=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_4=4103 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_4=4103 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr _ .\r\ntr '[:upper:]' '[:lower:]'\r\n+ kafka_name=advertised.listeners\r\n++ echo KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_ADVERTISED_LISTENERS\r\n+ egrep -q '(^|^#)advertised.listeners=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(advertised.listeners)=(.*)@\\2=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_PORT_9042_TCP=tcp://10.106.58.19:9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_PORT_9042_TCP=tcp://10.106.58.19:9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP_PORT=4000 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP_PORT=4000 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_SERVICE_PORT=443 =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_SERVICE_PORT=443 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_HOST=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_HOST=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_API_HTTP=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_API_HTTP=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP_ADDR=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP_ADDR=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP_PORT=4103 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP_PORT=4103 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_SERVICE_PORT_CASSANDRA_PORT=9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_SERVICE_PORT_CASSANDRA_PORT=9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP_PORT=4102 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP_PORT=4102 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP_ADDR=10.103.9.181 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP_ADDR=10.103.9.181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP_PORT=4103 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP_PORT=4103 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_SERVICE_HOST=10.96.0.1 =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_SERVICE_HOST=10.96.0.1 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP=tcp://10.98.201.219:4140 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP=tcp://10.98.201.219:4140 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_3=4003 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_3=4003 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_2181_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_2181_TCP_PROTO=tcp =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_2181_TCP_PROTO=tcp\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr _ .\r\n++ tr '[:upper:]' '[:lower:]'\r\n+ kafka_name=port.2181.tcp.proto\r\n++ echo KAFKA_PORT_2181_TCP_PROTO=tcp\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_2181_TCP_PROTO\r\n+ egrep -q '(^|^#)port.2181.tcp.proto=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.2181.tcp.proto)=(.*)@\\2=tcp@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_2181_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_9092_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_9092_TCP_PROTO=tcp =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_9092_TCP_PROTO=tcp\r\n++ ++ tr '[:upper:]' '[:lower:]'\r\nsed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr _ .\r\n+ kafka_name=port.9092.tcp.proto\r\n++ echo KAFKA_PORT_9092_TCP_PROTO=tcp\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_9092_TCP_PROTO\r\n+ egrep -q '(^|^#)port.9092.tcp.proto=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.9092.tcp.proto)=(.*)@\\2=tcp@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_9092_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ GLIBC_VERSION=2.26-r0 =~ ^KAFKA_ ]]\r\n+ [[ GLIBC_VERSION=2.26-r0 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP_ADDR=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP_ADDR=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_SERVICE_PORT_ZOOKEEPER_PORT=2181 =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_SERVICE_PORT_ZOOKEEPER_PORT=2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP_PORT=4002 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP_PORT=4002 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_SERVICE_PORT=9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_SERVICE_PORT=9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP=tcp://10.109.255.57:8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP=tcp://10.109.255.57:8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP=tcp://10.109.255.57:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP=tcp://10.109.255.57:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP_PORT=4140 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP_PORT=4140 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP=tcp://10.110.72.37:2181 =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP=tcp://10.110.72.37:2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP=tcp://10.103.9.181:9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP=tcp://10.103.9.181:9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP_ADDR=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP_ADDR=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_SERVICE_PORT_KAFKA_PORT=9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_SERVICE_PORT_KAFKA_PORT=9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_SERVICE_PORT_KAFKA_PORT=9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ tr _ .\r\n+ kafka_name=service.service.port.kafka.port\r\n++ echo KAFKA_SERVICE_SERVICE_PORT_KAFKA_PORT=9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_SERVICE_PORT_KAFKA_PORT\r\n+ egrep -q '(^|^#)service.service.port.kafka.port=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.service.port.kafka.port)=(.*)@\\2=9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_SERVICE_PORT_KAFKA_PORT=9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP=tcp://10.97.94.81:8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP=tcp://10.97.94.81:8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_SERVICE_PORT=9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_SERVICE_PORT=9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_SERVICE_PORT=9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ tr _ .\r\n+ kafka_name=service.service.port\r\n++ echo KAFKA_SERVICE_SERVICE_PORT=9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_SERVICE_PORT\r\n+ egrep -q '(^|^#)service.service.port=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.service.port)=(.*)@\\2=9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_SERVICE_PORT=9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP=tcp://10.97.94.81:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP=tcp://10.97.94.81:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_OPS_GRPC=4103 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_OPS_GRPC=4103 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP_ADDR=10.96.217.66 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP_ADDR=10.96.217.66 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_HOST=10.111.134.92 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_HOST=10.111.134.92 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_HOST=10.111.134.92\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr _ .\r\ntr '[:upper:]' '[:lower:]'\r\n+ kafka_name=service.host\r\n++ ++ sed -r 's/(.*)=.*/\\1/g'\r\necho KAFKA_SERVICE_HOST=10.111.134.92\r\n+ env_var=KAFKA_SERVICE_HOST\r\n+ egrep -q '(^|^#)service.host=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.host)=(.*)@\\2=10.111.134.92@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_HOST=10.111.134.92 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JAVA_JCE=standard =~ ^KAFKA_ ]]\r\n+ [[ JAVA_JCE=standard =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP_ADDR=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP_ADDR=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT=tcp://10.110.124.218:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT=tcp://10.110.124.218:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP_ADDR=10.110.124.218 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP_ADDR=10.110.124.218 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP=tcp://10.96.217.66:8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP=tcp://10.96.217.66:8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_PORT=tcp://10.110.185.158:9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_PORT=tcp://10.110.185.158:9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_PORT=tcp://10.110.185.158:9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr _ .\r\ntr '[:upper:]' '[:lower:]'\r\n+ kafka_name=service.port\r\n++ echo KAFKA_SERVICE_PORT=tcp://10.110.185.158:9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_PORT\r\n+ egrep -q '(^|^#)service.port=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.port)=(.*)@\\2=tcp://10.110.185.158:9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_PORT=tcp://10.110.185.158:9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP_ADDR=10.97.94.81 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4102_TCP_ADDR=10.97.94.81 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_HOST=10.96.217.66 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_HOST=10.96.217.66 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP=tcp://10.110.124.218:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP=tcp://10.110.124.218:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP_ADDR=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4103_TCP_ADDR=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/jdk/bin:/bin =~ ^KAFKA_ ]]\r\n+ [[ PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin:/opt/jdk/bin:/bin =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP_PORT=9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_PORT_9092_TCP_PORT=9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP_PORT=9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr '[:upper:]' '[:lower:]'\r\ntr _ .\r\n+ kafka_name=service.port.9092.tcp.port\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP_PORT=9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_PORT_9092_TCP_PORT\r\n+ egrep -q '(^|^#)service.port.9092.tcp.port=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.port.9092.tcp.port)=(.*)@\\2=9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP_PORT=9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP_ADDR=10.110.72.37 =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP_ADDR=10.110.72.37 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP_ADDR=10.109.255.57 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP_ADDR=10.109.255.57 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP_PORT=4100 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP_PORT=4100 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP=tcp://10.109.255.57:4003 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP=tcp://10.109.255.57:4003 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ GLIBC_REPO=https://github.com/sgerrand/alpine-pkg-glibc =~ ^KAFKA_ ]]\r\n+ [[ GLIBC_REPO=https://github.com/sgerrand/alpine-pkg-glibc =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_SERVICE_HOST=10.110.185.158 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_SERVICE_HOST=10.110.185.158 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_SERVICE_HOST=10.110.185.158\r\n++ ++ tr sed '[:upper:]' -r 's/KAFKA_(.*)=.*/\\1/g''[:lower:]'++ tr _ .\r\n\r\n\r\n+ kafka_name=service.service.host\r\n++ echo KAFKA_SERVICE_SERVICE_HOST=10.110.185.158\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_SERVICE_HOST\r\n+ egrep -q '(^|^#)service.service.host=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.service.host)=(.*)@\\2=10.110.185.158@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_SERVICE_HOST=10.110.185.158 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP_PORT=4003 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP_PORT=4003 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_VERSION=1.0.0 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_VERSION=1.0.0 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_VERSION=1.0.0\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr '[:upper:]' '[:lower:]'\r\ntr _ .\r\n+ kafka_name=version\r\n++ echo KAFKA_VERSION=1.0.0\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_VERSION\r\n+ egrep -q '(^|^#)version=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(version)=(.*)@\\2=1.0.0@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_VERSION=1.0.0 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_PORT=tcp://10.106.58.19:9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_PORT=tcp://10.106.58.19:9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP_ADDR=10.97.94.81 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP_ADDR=10.97.94.81 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT=tcp://10.98.201.219:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT=tcp://10.98.201.219:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ PWD=/kafka =~ ^KAFKA_ ]]\r\n+ [[ PWD=/kafka =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JAVA_HOME=/opt/jdk =~ ^KAFKA_ ]]\r\n+ [[ JAVA_HOME=/opt/jdk =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_HOST=10.106.58.19 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_HOST=10.106.58.19 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_PORT_9042_TCP_ADDR=10.106.58.19 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_PORT_9042_TCP_ADDR=10.106.58.19 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_HTTP=4140 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_HTTP=4140 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ LANG=C.UTF-8 =~ ^KAFKA_ ]]\r\n+ [[ LANG=C.UTF-8 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP_PORT=2181 =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP_PORT=2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_PORT_9042_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_PORT_9042_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT=tcp://10.97.94.81:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT=tcp://10.97.94.81:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP_ADDR=10.109.255.57 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP_ADDR=10.109.255.57 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_LOG_DIRS=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_LOG_DIRS=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_LOG_DIRS=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ tr _ .\r\n+ kafka_name=log.dirs\r\n++ echo KAFKA_LOG_DIRS=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_LOG_DIRS\r\n+ egrep -q '(^|^#)log.dirs=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(log.dirs)=(.*)@\\2=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_LOG_DIRS=/kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_4=4100 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_4=4100 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP_PORT=4101 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP_PORT=4101 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_GRPC=5150 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_GRPC=5150 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_PORT=9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_PORT=9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP_ADDR=10.110.124.218 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP_ADDR=10.110.124.218 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP_ADDR=10.96.217.66 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP_ADDR=10.96.217.66 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_HOST=10.97.94.81 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_HOST=10.97.94.81 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ HOME=/root =~ ^KAFKA_ ]]\r\n+ [[ HOME=/root =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ SHLVL=2 =~ ^KAFKA_ ]]\r\n+ [[ SHLVL=2 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_PORT_2181_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP=tcp://10.96.217.66:4101 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP=tcp://10.96.217.66:4101 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP_ADDR=10.109.255.57 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP_ADDR=10.109.255.57 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_PORT_443_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_PORT_443_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP=tcp://10.109.255.57:4103 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4103_TCP=tcp://10.109.255.57:4103 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_3=4000 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT_PORT_3=4000 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_SERVICE_PORT_HTTPS=443 =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_SERVICE_PORT_HTTPS=443 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_3=4001 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_3=4001 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_9092_TCP=tcp://10.111.134.92:9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_9092_TCP=tcp://10.111.134.92:9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_9092_TCP=tcp://10.111.134.92:9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr _ tr .'[:upper:]' \r\n'[:lower:]'\r\n+ kafka_name=port.9092.tcp\r\n++ echo KAFKA_PORT_9092_TCP=tcp://10.111.134.92:9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_9092_TCP\r\n+ egrep -q '(^|^#)port.9092.tcp=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.9092.tcp)=(.*)@\\2=tcp://10.111.134.92:9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_9092_TCP=tcp://10.111.134.92:9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP=tcp://10.98.201.219:5150 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP=tcp://10.98.201.219:5150 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_2181_TCP=tcp://10.111.134.92:2181 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_2181_TCP=tcp://10.111.134.92:2181 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_2181_TCP=tcp://10.111.134.92:2181\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ ++ tr '[:upper:]' '[:lower:]'\r\ntr _ .\r\n+ kafka_name=port.2181.tcp\r\n++ echo KAFKA_PORT_2181_TCP=tcp://10.111.134.92:2181\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_2181_TCP\r\n+ egrep -q '(^|^#)port.2181.tcp=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.2181.tcp)=(.*)@\\2=tcp://10.111.134.92:2181@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_2181_TCP=tcp://10.111.134.92:2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JAVA_PACKAGE=server-jre =~ ^KAFKA_ ]]\r\n+ [[ JAVA_PACKAGE=server-jre =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP=tcp://10.96.217.66:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP=tcp://10.96.217.66:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP_ADDR=10.97.94.81 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8081_TCP_ADDR=10.97.94.81 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT=tcp://10.109.255.57:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT=tcp://10.109.255.57:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_HOST=10.110.124.218 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_HOST=10.110.124.218 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP_ADDR=10.96.217.66 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8081_TCP_ADDR=10.96.217.66 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_API_GRPC=4003 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_API_GRPC=4003 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP=tcp://10.98.201.219:4003 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP=tcp://10.98.201.219:4003 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP=tcp://10.98.201.219:8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP=tcp://10.98.201.219:8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_HTTP_INGRESS=4142 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_HTTP_INGRESS=4142 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP=tcp://10.98.201.219:8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8081_TCP=tcp://10.98.201.219:8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_SERVICE_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_4=4101 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_SERVICE_PORT_PORT_4=4101 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_8080_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_SERVICE_HOST=10.110.72.37 =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_SERVICE_HOST=10.110.72.37 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP=tcp://10.98.201.219:4142 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4142_TCP=tcp://10.98.201.219:4142 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_OPS_HTTP=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT_JURO_KAFKA_OPS_HTTP=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_LISTENERS=PLAINTEXT://:tcp://10.111.134.92:9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_LISTENERS=PLAINTEXT://:tcp://10.111.134.92:9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_LISTENERS=PLAINTEXT://:tcp://10.111.134.92:9092\r\n++ tr _ .\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n+ kafka_name=listeners\r\n++ echo KAFKA_LISTENERS=PLAINTEXT://:tcp://10.111.134.92:9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_LISTENERS\r\n+ egrep -q '(^|^#)listeners=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(listeners)=(.*)@\\2=PLAINTEXT://:tcp://10.111.134.92:9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_LISTENERS=PLAINTEXT://:tcp://10.111.134.92:9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP_PORT=4003 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_4003_TCP_PORT=4003 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP_ADDR=10.96.217.66 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4101_TCP_ADDR=10.96.217.66 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4003_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_1=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP=tcp://10.110.185.158:9092 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_SERVICE_PORT_9092_TCP=tcp://10.110.185.158:9092 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP=tcp://10.110.185.158:9092\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ tr _ .\r\n+ kafka_name=service.port.9092.tcp\r\n++ echo KAFKA_SERVICE_PORT_9092_TCP=tcp://10.110.185.158:9092\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_SERVICE_PORT_9092_TCP\r\n+ egrep -q '(^|^#)service.port.9092.tcp=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(service.port.9092.tcp)=(.*)@\\2=tcp://10.110.185.158:9092@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_SERVICE_PORT_9092_TCP=tcp://10.110.185.158:9092 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP=tcp://10.110.124.218:4100 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4100_TCP=tcp://10.110.124.218:4100 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_BROKER_ID=-1 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_BROKER_ID=-1 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_BROKER_ID=-1\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ tr _ .\r\n+ kafka_name=broker.id\r\n++ echo KAFKA_BROKER_ID=-1\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_BROKER_ID\r\n+ egrep -q '(^|^#)broker.id=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(broker.id)=(.*)@\\2=-1@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_BROKER_ID=-1 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_4140_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_3=4002 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_3=4002 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_RUNTIME_PORT_8081_TCP_PORT=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_PORT_443_TCP_ADDR=10.96.0.1 =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_PORT_443_TCP_ADDR=10.96.0.1 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_SERVICE_HOST=10.103.9.181 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_SERVICE_HOST=10.103.9.181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP_PORT=4001 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP_PORT=4001 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_2=8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP_ADDR=10.97.94.81 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_PORT_4002_TCP_ADDR=10.97.94.81 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JAVA_VERSION_MINOR=152 =~ ^KAFKA_ ]]\r\n+ [[ JAVA_VERSION_MINOR=152 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ ZOOKEEPER_SERVICE_SERVICE_PORT=2181 =~ ^KAFKA_ ]]\r\n+ [[ ZOOKEEPER_SERVICE_SERVICE_PORT=2181 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP_PORT=9042 =~ ^KAFKA_ ]]\r\n+ [[ CASSANDRA_SERVICE_PORT_9042_TCP_PORT=9042 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KUBERNETES_PORT_443_TCP=tcp://10.96.0.1:443 =~ ^KAFKA_ ]]\r\n+ [[ KUBERNETES_PORT_443_TCP=tcp://10.96.0.1:443 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_9092_TCP_ADDR=10.111.134.92 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_9092_TCP_ADDR=10.111.134.92 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_9092_TCP_ADDR=10.111.134.92\r\n++ tr '[:upper:]' '[:lower:]'\r\n++ tr _ .\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n+ kafka_name=port.9092.tcp.addr\r\n++ echo KAFKA_PORT_9092_TCP_ADDR=10.111.134.92\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_9092_TCP_ADDR\r\n+ egrep -q '(^|^#)port.9092.tcp.addr=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.9092.tcp.addr)=(.*)@\\2=10.111.134.92@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_9092_TCP_ADDR=10.111.134.92 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_4=4102 =~ ^KAFKA_ ]]\r\n+ [[ JURO_NETWORK_RUNTIME_SERVICE_PORT_PORT_4=4102 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ KAFKA_PORT_2181_TCP_ADDR=10.111.134.92 =~ ^KAFKA_ ]]\r\n+ [[ ! KAFKA_PORT_2181_TCP_ADDR=10.111.134.92 =~ ^KAFKA_HOME ]]\r\n++ echo KAFKA_PORT_2181_TCP_ADDR=10.111.134.92\r\n++ sed -r 's/KAFKA_(.*)=.*/\\1/g'\r\n++ tr _ .\r\n++ tr '[:upper:]' '[:lower:]'\r\n+ kafka_name=port.2181.tcp.addr\r\n++ echo KAFKA_PORT_2181_TCP_ADDR=10.111.134.92\r\n++ sed -r 's/(.*)=.*/\\1/g'\r\n+ env_var=KAFKA_PORT_2181_TCP_ADDR\r\n+ egrep -q '(^|^#)port.2181.tcp.addr=' /opt/kafka/config/server.properties\r\n+ sed -r -i 's@(^|^#)(port.2181.tcp.addr)=(.*)@\\2=10.111.134.92@g' /opt/kafka/config/server.properties\r\n+ [[ KAFKA_PORT_2181_TCP_ADDR=10.111.134.92 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_8080_TCP_PROTO=tcp =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP_ADDR=10.98.201.219 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_PORT_5150_TCP_ADDR=10.98.201.219 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT=8080 =~ ^KAFKA_ ]]\r\n+ [[ JURO_KAFKA_SERVICE_SERVICE_PORT=8080 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP=tcp://10.110.124.218:8081 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_8081_TCP=tcp://10.110.124.218:8081 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP_ADDR=10.110.124.218 =~ ^KAFKA_ ]]\r\n+ [[ JURO_JIN_RUNTIME_PORT_4000_TCP_ADDR=10.110.124.218 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP=tcp://10.96.217.66:4001 =~ ^KAFKA_ ]]\r\n+ [[ JURO_CONNECTOR_RUNTIME_PORT_4001_TCP=tcp://10.96.217.66:4001 =~ ^LOG4J_ ]]\r\n+ for VAR in '`env`'\r\n+ [[ _=/usr/bin/env =~ ^KAFKA_ ]]\r\n+ [[ _=/usr/bin/env =~ ^LOG4J_ ]]\r\n+ [[ -n '' ]]\r\n+ exec /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties\r\n[2018-02-11 13:40:19,522] INFO KafkaConfig values: \r\n\tadvertised.host.name = null\r\n\tadvertised.listeners = PLAINTEXT://127.0.0.1:tcp://10.111.134.92:9092\r\n\tadvertised.port = null\r\n\talter.config.policy.class.name = null\r\n\tauthorizer.class.name = \r\n\tauto.create.topics.enable = true\r\n\tauto.leader.rebalance.enable = true\r\n\tbackground.threads = 10\r\n\tbroker.id = -1\r\n\tbroker.id.generation.enable = true\r\n\tbroker.rack = null\r\n\tcompression.type = producer\r\n\tconnections.max.idle.ms = 600000\r\n\tcontrolled.shutdown.enable = true\r\n\tcontrolled.shutdown.max.retries = 3\r\n\tcontrolled.shutdown.retry.backoff.ms = 5000\r\n\tcontroller.socket.timeout.ms = 30000\r\n\tcreate.topic.policy.class.name = null\r\n\tdefault.replication.factor = 1\r\n\tdelete.records.purgatory.purge.interval.requests = 1\r\n\tdelete.topic.enable = true\r\n\tfetch.purgatory.purge.interval.requests = 1000\r\n\tgroup.initial.rebalance.delay.ms = 0\r\n\tgroup.max.session.timeout.ms = 300000\r\n\tgroup.min.session.timeout.ms = 6000\r\n\thost.name = \r\n\tinter.broker.listener.name = null\r\n\tinter.broker.protocol.version = 1.0-IV0\r\n\tleader.imbalance.check.interval.seconds = 300\r\n\tleader.imbalance.per.broker.percentage = 10\r\n\tlistener.security.protocol.map = PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT,SASL_SSL:SASL_SSL\r\n\tlisteners = PLAINTEXT://:tcp://10.111.134.92:9092\r\n\tlog.cleaner.backoff.ms = 15000\r\n\tlog.cleaner.dedupe.buffer.size = 134217728\r\n\tlog.cleaner.delete.retention.ms = 86400000\r\n\tlog.cleaner.enable = true\r\n\tlog.cleaner.io.buffer.load.factor = 0.9\r\n\tlog.cleaner.io.buffer.size = 524288\r\n\tlog.cleaner.io.max.bytes.per.second = 1.7976931348623157E308\r\n\tlog.cleaner.min.cleanable.ratio = 0.5\r\n\tlog.cleaner.min.compaction.lag.ms = 0\r\n\tlog.cleaner.threads = 1\r\n\tlog.cleanup.policy = [delete]\r\n\tlog.dir = /tmp/kafka-logs\r\n\tlog.dirs = /kafka/kafka-logs-kafka-6d5ff44f6c-hqrtz\r\n\tlog.flush.interval.messages = 9223372036854775807\r\n\tlog.flush.interval.ms = null\r\n\tlog.flush.offset.checkpoint.interval.ms = 60000\r\n\tlog.flush.scheduler.interval.ms = 9223372036854775807\r\n\tlog.flush.start.offset.checkpoint.interval.ms = 60000\r\n\tlog.index.interval.bytes = 4096\r\n\tlog.index.size.max.bytes = 10485760\r\n\tlog.message.format.version = 1.0-IV0\r\n\tlog.message.timestamp.difference.max.ms = 9223372036854775807\r\n\tlog.message.timestamp.type = CreateTime\r\n\tlog.preallocate = false\r\n\tlog.retention.bytes = -1\r\n\tlog.retention.check.interval.ms = 300000\r\n\tlog.retention.hours = 168\r\n\tlog.retention.minutes = null\r\n\tlog.retention.ms = null\r\n\tlog.roll.hours = 168\r\n\tlog.roll.jitter.hours = 0\r\n\tlog.roll.jitter.ms = null\r\n\tlog.roll.ms = null\r\n\tlog.segment.bytes = 1073741824\r\n\tlog.segment.delete.delay.ms = 60000\r\n\tmax.connections.per.ip = 2147483647\r\n\tmax.connections.per.ip.overrides = \r\n\tmessage.max.bytes = 1000012\r\n\tmetric.reporters = []\r\n\tmetrics.num.samples = 2\r\n\tmetrics.recording.level = INFO\r\n\tmetrics.sample.window.ms = 30000\r\n\tmin.insync.replicas = 1\r\n\tnum.io.threads = 8\r\n\tnum.network.threads = 3\r\n\tnum.partitions = 1\r\n\tnum.recovery.threads.per.data.dir = 1\r\n\tnum.replica.fetchers = 1\r\n\toffset.metadata.max.bytes = 4096\r\n\toffsets.commit.required.acks = -1\r\n\toffsets.commit.timeout.ms = 5000\r\n\toffsets.load.buffer.size = 5242880\r\n\toffsets.retention.check.interval.ms = 600000\r\n\toffsets.retention.minutes = 1440\r\n\toffsets.topic.compression.codec = 0\r\n\toffsets.topic.num.partitions = 50\r\n\toffsets.topic.replication.factor = 1\r\n\toffsets.topic.segment.bytes = 104857600\r\n\tport = 9092\r\n\tprincipal.builder.class = null\r\n\tproducer.purgatory.purge.interval.requests = 1000\r\n\tqueued.max.request.bytes = -1\r\n\tqueued.max.requests = 500\r\n\tquota.consumer.default = 9223372036854775807\r\n\tquota.producer.default = 9223372036854775807\r\n\tquota.window.num = 11\r\n\tquota.window.size.seconds = 1\r\n\treplica.fetch.backoff.ms = 1000\r\n\treplica.fetch.max.bytes = 1048576\r\n\treplica.fetch.min.bytes = 1\r\n\treplica.fetch.response.max.bytes = 10485760\r\n\treplica.fetch.wait.max.ms = 500\r\n\treplica.high.watermark.checkpoint.interval.ms = 5000\r\n\treplica.lag.time.max.ms = 10000\r\n\treplica.socket.receive.buffer.bytes = 65536\r\n\treplica.socket.timeout.ms = 30000\r\n\treplication.quota.window.num = 11\r\n\treplication.quota.window.size.seconds = 1\r\n\trequest.timeout.ms = 30000\r\n\treserved.broker.max.id = 1000\r\n\tsasl.enabled.mechanisms = [GSSAPI]\r\n\tsasl.kerberos.kinit.cmd = /usr/bin/kinit\r\n\tsasl.kerberos.min.time.before.relogin = 60000\r\n\tsasl.kerberos.principal.to.local.rules = [DEFAULT]\r\n\tsasl.kerberos.service.name = null\r\n\tsasl.kerberos.ticket.renew.jitter = 0.05\r\n\tsasl.kerberos.ticket.renew.window.factor = 0.8\r\n\tsasl.mechanism.inter.broker.protocol = GSSAPI\r\n\tsecurity.inter.broker.protocol = PLAINTEXT\r\n\tsocket.receive.buffer.bytes = 102400\r\n\tsocket.request.max.bytes = 104857600\r\n\tsocket.send.buffer.bytes = 102400\r\n\tssl.cipher.suites = null\r\n\tssl.client.auth = none\r\n\tssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]\r\n\tssl.endpoint.identification.algorithm = null\r\n\tssl.key.password = null\r\n\tssl.keymanager.algorithm = SunX509\r\n\tssl.keystore.location = null\r\n\tssl.keystore.password = null\r\n\tssl.keystore.type = JKS\r\n\tssl.protocol = TLS\r\n\tssl.provider = null\r\n\tssl.secure.random.implementation = null\r\n\tssl.trustmanager.algorithm = PKIX\r\n\tssl.truststore.location = null\r\n\tssl.truststore.password = null\r\n\tssl.truststore.type = JKS\r\n\ttransaction.abort.timed.out.transaction.cleanup.interval.ms = 60000\r\n\ttransaction.max.timeout.ms = 900000\r\n\ttransaction.remove.expired.transaction.cleanup.interval.ms = 3600000\r\n\ttransaction.state.log.load.buffer.size = 5242880\r\n\ttransaction.state.log.min.isr = 1\r\n\ttransaction.state.log.num.partitions = 50\r\n\ttransaction.state.log.replication.factor = 1\r\n\ttransaction.state.log.segment.bytes = 104857600\r\n\ttransactional.id.expiration.ms = 604800000\r\n\tunclean.leader.election.enable = false\r\n\tzookeeper.connect = 127.0.0.1:2181\r\n\tzookeeper.connection.timeout.ms = 6000\r\n\tzookeeper.session.timeout.ms = 6000\r\n\tzookeeper.set.acl = false\r\n\tzookeeper.sync.time.ms = 2000\r\n (kafka.server.KafkaConfig)\r\n[2018-02-11 13:40:19,553] FATAL  (kafka.Kafka$)\r\njava.lang.IllegalArgumentException: Error creating broker listeners from 'PLAINTEXT://:tcp://10.111.134.92:9092': No security protocol defined for listener PLAINTEXT://:TCP\r\n\tat kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:278)\r\n\tat kafka.server.KafkaConfig.$anonfun$getListeners$1(KafkaConfig.scala:1120)\r\n\tat scala.Option.map(Option.scala:146)\r\n\tat kafka.server.KafkaConfig.getListeners(KafkaConfig.scala:1119)\r\n\tat kafka.server.KafkaConfig.<init>(KafkaConfig.scala:1089)\r\n\tat kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:881)\r\n\tat kafka.server.KafkaConfig$.fromProps(KafkaConfig.scala:878)\r\n\tat kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:28)\r\n\tat kafka.Kafka$.main(Kafka.scala:82)\r\n\tat kafka.Kafka.main(Kafka.scala)\r\nCaused by: java.lang.IllegalArgumentException: No security protocol defined for listener PLAINTEXT://:TCP\r\n\tat kafka.cluster.EndPoint$.$anonfun$createEndPoint$2(EndPoint.scala:48)\r\n\tat scala.collection.MapLike.getOrElse(MapLike.scala:128)\r\n\tat scala.collection.MapLike.getOrElse$(MapLike.scala:126)\r\n\tat scala.collection.AbstractMap.getOrElse(Map.scala:59)\r\n\tat kafka.cluster.EndPoint$.securityProtocol$1(EndPoint.scala:48)\r\n\tat kafka.cluster.EndPoint$.createEndPoint(EndPoint.scala:56)\r\n\tat kafka.utils.CoreUtils$.$anonfun$listenerListToEndPoints$6(CoreUtils.scala:275)\r\n\tat scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:234)\r\n\tat scala.collection.IndexedSeqOptimized.foreach(IndexedSeqOptimized.scala:32)\r\n\tat scala.collection.IndexedSeqOptimized.foreach$(IndexedSeqOptimized.scala:29)\r\n\tat scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:38)\r\n\tat scala.collection.TraversableLike.map(TraversableLike.scala:234)\r\n\tat scala.collection.TraversableLike.map$(TraversableLike.scala:227)\r\n\tat scala.collection.AbstractTraversable.map(Traversable.scala:104)\r\n\tat kafka.utils.CoreUtils$.listenerListToEndPoints(CoreUtils.scala:275)\r\n\t... 9 more\r\n```\r\n"}}
{"actor":{"display_login":"sscaling"}}