Replace Eclipselink with Hibernate

[policy/apex-pdp.git] / plugins / plugins-event / plugins-event-carrier / plugins-event-carrier-kafka / src / test / java / org / onap / policy / apex / plugins / event / carrier / kafka / KafkaCarrierTechnologyParametersTest.java

diff --git a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java
index 14f13bc..6b0f7d9 100644 (file)
--- a/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java
+++ b/plugins/plugins-event/plugins-event-carrier/plugins-event-carrier-kafka/src/test/java/org/onap/policy/apex/plugins/event/carrier/kafka/KafkaCarrierTechnologyParametersTest.java
@@ -1,7 +1,7 @@
 /*-
  * ============LICENSE_START=======================================================
  *  Copyright (C) 2019 Samsung. All rights reserved.
- *  Modifications Copyright (C) 2019 Nordix Foundation.
+ *  Modifications Copyright (C) 2019,2023 Nordix Foundation.
  *  Modifications Copyright (C) 2021 Bell Canada. All rights reserved.
  * ================================================================================
  * Licensed under the Apache License, Version 2.0 (the "License");
@@ -140,12 +140,6 @@ public class KafkaCarrierTechnologyParametersTest {
         kafkaCarrierTechnologyParameters.setProducerTopic(origStringValue);
         assertTrue(kafkaCarrierTechnologyParameters.validate().isValid());
 
-        origStringValue = kafkaCarrierTechnologyParameters.getPartitionerClass();
-        kafkaCarrierTechnologyParameters.setPartitionerClass(" ");
-        assertFalse(kafkaCarrierTechnologyParameters.validate().isValid());
-        kafkaCarrierTechnologyParameters.setPartitionerClass(origStringValue);
-        assertTrue(kafkaCarrierTechnologyParameters.validate().isValid());
-
         int origIntValue = kafkaCarrierTechnologyParameters.getRetries();
         kafkaCarrierTechnologyParameters.setRetries(-1);
         assertFalse(kafkaCarrierTechnologyParameters.validate().isValid());
@@ -333,8 +327,6 @@ public class KafkaCarrierTechnologyParametersTest {
                 kafkaCtp.getKafkaConsumerProperties().get("key.deserializer"));
         assertEquals("org.apache.kafka.common.serialization.StringDeserializer",
                 kafkaCtp.getKafkaConsumerProperties().get("value.deserializer"));
-        assertEquals("org.apache.kafka.clients.producer.internals.DefaultPartitioner",
-                kafkaCtp.getKafkaProducerProperties().get("partitioner.class"));
 
         // @formatter:off
         String[][] kafkaProperties0 = {