[VOL-2364] Adding required methods to InterContainerProxy interface
Change-Id: Idaeb3f40c4979c456f66209ba0a073242c8545d8
diff --git a/pkg/kafka/kafka_inter_container_library_test.go b/pkg/kafka/kafka_inter_container_library_test.go
index f9888c0..abec85f 100644
--- a/pkg/kafka/kafka_inter_container_library_test.go
+++ b/pkg/kafka/kafka_inter_container_library_test.go
@@ -50,7 +50,7 @@
assert.Equal(t, actualResult.kafkaHost, DefaultKafkaHost)
assert.Equal(t, actualResult.kafkaPort, DefaultKafkaPort)
assert.Equal(t, actualResult.defaultRequestHandlerInterface, interface{}(nil))
- assert.Equal(t, actualResult.DefaultTopic.Name, "Adapter")
+ assert.Equal(t, actualResult.defaultTopic.Name, "Adapter")
}
type myInterface struct {
@@ -79,7 +79,7 @@
assert.Equal(t, actualResult.kafkaHost, "10.20.30.40")
assert.Equal(t, actualResult.kafkaPort, 1020)
assert.Equal(t, actualResult.defaultRequestHandlerInterface, m)
- assert.Equal(t, actualResult.DefaultTopic.Name, "Adapter")
+ assert.Equal(t, actualResult.defaultTopic.Name, "Adapter")
}
func TestKafkaProxyEnableLivenessChannel(t *testing.T) {