Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/21955#discussion_r207392910
--- 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 --
And then in `brokerConfiguration` below, I need to add something like these
props?
offsets.topic.replication.factor -> 1
group.initial.rebalance.delay.ms -> 10
default.api.timeout.ms -> 3000
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
