Kafa - Kafka

ExpediaGroup · Sep 17, 2020 · 99d2863 · 99d2863
1 parent 816eeff
commit 99d2863
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...java/com/expediagroup/dataplatform/dronefly/core/integration/DroneFlyIntegrationTest.java b/...java/com/expediagroup/dataplatform/dronefly/core/integration/DroneFlyIntegrationTest.java
@@ -101,7 +101,7 @@ void setUp() throws InterruptedException {
      * complete.
      * https://stackoverflow.com/questions/47312373/embeddedkafka-sending-messages-to-consumer-after-delay-in-subsequent-test
      */
-    initEmbeddedKafa();
+    initEmbeddedKafka();
     System.setProperty("instance.name", "test");
     System.setProperty("apiary.bootstrap.servers", embeddedKafkaBroker.getBrokersAsString());
     System.setProperty("apiary.kafka.topic.name", TOPIC);
@@ -171,7 +171,7 @@ private void assertEvent(ListenerEvent event, EventType eventType) {
     }
   }
 
-  private void initEmbeddedKafa() {
+  private void initEmbeddedKafka() {
     Map<String, Object> configs = new HashMap<>(KafkaTestUtils.consumerProps("consumer", "false", embeddedKafkaBroker));
     DefaultKafkaConsumerFactory<String, String> consumerFactory = new DefaultKafkaConsumerFactory<>(configs,
         new StringDeserializer(), new StringDeserializer());

diff --git a/...com/expediagroup/dataplatform/dronefly/core/integration/DroneFlyIntegrationTestUtils.java b/...com/expediagroup/dataplatform/dronefly/core/integration/DroneFlyIntegrationTestUtils.java
@@ -46,7 +46,7 @@ public static Table buildTable(String tableName) {
   }
 
   public static Partition buildPartition() {
-    return buildPartition(null);
+    return buildPartition("partition");
   }
 
   public static Partition buildPartition(String partitionName) {