Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/21955#discussion_r207663151
--- Diff:
external/kafka-0-10/src/test/scala/org/apache/spark/streaming/kafka010/KafkaTestUtils.scala
---
@@ -109,7 +109,7 @@ private[kafka010] class KafkaTestUtils extends Logging {
brokerConf = new KafkaConfig(brokerConfiguration, doLog = false)
server = new KafkaServer(brokerConf)
server.startup()
- brokerPort = server.boundPort()
+ brokerPort = server.boundPort(brokerConf.interBrokerListenerName)
--- End diff --
In particular @zsxwing , regarding the failure below, I wonder if my change
on this line really wasn't quite equivalent. Is it possible it needs to be
"PLAINTEXT" like in yours?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
