ISSUE #150

* Fix renaming bug.

Author: Sergio García Prado

packages/plugins/minos-broker-kafka/tests/test_kafka/test_common.py

@@ -33,8 +33,8 @@ def test_constructor(self):
 
         expected = {
             "group_id": config.get_name(),
-            "broker_host": common_config["host"],
-            "broker_port": common_config["port"],
+            "host": common_config["host"],
+            "port": common_config["port"],
         }
         self.assertEqual(expected, mixin.kwargs)
 

packages/plugins/minos-broker-kafka/tests/test_kafka/test_publisher.py

@@ -136,8 +136,8 @@ def test_with_config(self):
 
         expected = {
             "group_id": self.config.get_name(),
-            "broker_host": common_config["host"],
-            "broker_port": common_config["port"],
+            "host": common_config["host"],
+            "port": common_config["port"],
         }
         self.assertEqual(expected, builder.kwargs)
 
@@ -147,8 +147,8 @@ def test_build(self):
         publisher = builder.build()
 
         self.assertIsInstance(publisher, KafkaBrokerPublisher)
-        self.assertEqual(common_config["host"], publisher.broker_host)
-        self.assertEqual(common_config["port"], publisher.broker_port)
+        self.assertEqual(common_config["host"], publisher.host)
+        self.assertEqual(common_config["port"], publisher.port)
 
 
 class TestPostgreSqlQueuedKafkaBrokerPublisher(unittest.IsolatedAsyncioTestCase):