root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

Cleaned up unecessary toString calls

This commit is contained in:
Geoff Anderson 2015-07-09 13:08:09 -07:00
parent 23b3340b91
commit 52a2085fad
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
View File

@ -155,13 +155,12 @@ class KafkaConfigTest extends JUnit3Suite {
@Test @Test
def testAdvertiseConfigured() { def testAdvertiseConfigured() {
val port = "9999"
val advertisedHostName = "routable-host" val advertisedHostName = "routable-host"
val advertisedPort = "1234" val advertisedPort = "1234"
val props = TestUtils.createBrokerConfig(0, TestUtils.MockZkConnect) val props = TestUtils.createBrokerConfig(0, TestUtils.MockZkConnect)
props.put(KafkaConfig.AdvertisedHostNameProp, advertisedHostName) props.put(KafkaConfig.AdvertisedHostNameProp, advertisedHostName)
props.put(KafkaConfig.AdvertisedPortProp, advertisedPort.toString) props.put(KafkaConfig.AdvertisedPortProp, advertisedPort)
val serverConfig = KafkaConfig.fromProps(props) val serverConfig = KafkaConfig.fromProps(props)
val endpoints = serverConfig.advertisedListeners val endpoints = serverConfig.advertisedListeners
@ -178,7 +177,7 @@ class KafkaConfigTest extends JUnit3Suite {
val props = TestUtils.createBrokerConfig(0, TestUtils.MockZkConnect) val props = TestUtils.createBrokerConfig(0, TestUtils.MockZkConnect)
props.put(KafkaConfig.AdvertisedHostNameProp, advertisedHostName) props.put(KafkaConfig.AdvertisedHostNameProp, advertisedHostName)
props.put(KafkaConfig.PortProp, port.toString) props.put(KafkaConfig.PortProp, port)
val serverConfig = KafkaConfig.fromProps(props) val serverConfig = KafkaConfig.fromProps(props)
val endpoints = serverConfig.advertisedListeners val endpoints = serverConfig.advertisedListeners
@ -195,7 +194,7 @@ class KafkaConfigTest extends JUnit3Suite {
val props = TestUtils.createBrokerConfig(0, TestUtils.MockZkConnect) val props = TestUtils.createBrokerConfig(0, TestUtils.MockZkConnect)
props.put(KafkaConfig.HostNameProp, hostName) props.put(KafkaConfig.HostNameProp, hostName)
props.put(KafkaConfig.AdvertisedPortProp, advertisedPort.toString) props.put(KafkaConfig.AdvertisedPortProp, advertisedPort)
val serverConfig = KafkaConfig.fromProps(props) val serverConfig = KafkaConfig.fromProps(props)
val endpoints = serverConfig.advertisedListeners val endpoints = serverConfig.advertisedListeners