Enable TLS, v0.9.0.1

[flozano]

No description provided.

[zoidyzoidzoid]

Hi @mattnworb, would it be possible to get someone to look at all these PRs?

Even if it's just to say you guys aren't willing to merge them, or that you are gonna get to them.

[l15k4]

@jolivares Hey, I cannot figure out how to start the container after the SSL feature has been added. I'm using this image only for development so I'm not interested in SSL. Would you please update README ?

Doing this :

docker run --rm -p 9092:9092 -p 2181:2181 --name kafka --env ADVERTISED_HOST=localhost --env ADVERTISED_PORT=9092 flozano/kafka

crashes kafka container on start and doing this :

docker run --rm -p 9092:9092 -p 2181:2181 --name kafka --env ADVERTISED_HOST=localhost --env ADVERTISED_PORT=9092 --env ADVERTISED_SSL_PORT=9093 flozano/kafka

leads to client errors :

17:23:16.541 WARN  o.apache.kafka.clients.NetworkClient - Error while fetching metadata with correlation id 385 : {topic2=LEADER_NOT_AVAILABLE}

And server errors :

java.io.IOException: Connection to Node(0, localhost, 9093) failed
        at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$1.apply(NetworkClientBlockingOps.scala:62)
        at kafka.utils.NetworkClientBlockingOps$$anonfun$blockingReady$extension$1.apply(NetworkClientBlockingOps.scala:58)
        at kafka.utils.NetworkClientBlockingOps$$anonfun$kafka$utils$NetworkClientBlockingOps$$pollUntil$extension$2.apply(NetworkClientBlockingOps.scala:106)
        at kafka.utils.NetworkClientBlockingOps$$anonfun$kafka$utils$NetworkClientBlockingOps$$pollUntil$extension$2.apply(NetworkClientBlockingOps.scala:105)
        at kafka.utils.NetworkClientBlockingOps$.recurse$1(NetworkClientBlockingOps.scala:129)
        at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntilFound$extension(NetworkClientBlockingOps.scala:139)
        at kafka.utils.NetworkClientBlockingOps$.kafka$utils$NetworkClientBlockingOps$$pollUntil$extension(NetworkClientBlockingOps.scala:105)
        at kafka.utils.NetworkClientBlockingOps$.blockingReady$extension(NetworkClientBlockingOps.scala:58)
        at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:225)
        at kafka.controller.RequestSendThread.liftedTree1$1(ControllerChannelManager.scala:172)
        at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:171)
        at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)

[flozano]

@l15k4 in https://hub.docker.com/r/flozano/kafka/tags/ if you use "0.9" tag it doesnt' have any TLS. @jolivares is updating that right now, but in the meantime you can use that tag if you don't need TLS.

[l15k4]

@flozano I need the delete.topic.enable=true commit so I'm gonna inherit from the 0.9.0.0 tag for now, thanks