changed in integration test

src/test/java/com/safeway/epe/avrokafkawithoutschemaregistry/producer/PromotionProducerIntegrationTest.java

@@ -4,6 +4,7 @@ import com.safeway.epe.avrokafkawithoutschemaregistry.consumer.PromotionConsumer
 import com.safeway.epe.avrokafkawithoutschemaregistry.serializer.KafkaAvroDeserialize;
 import com.safeway.epe.avrokafkawithoutschemaregistry.serializer.KafkaAvroSerialize;
 import com.safeway.epe.model.Promotion;
+import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.clients.producer.KafkaProducer;
 import org.apache.kafka.clients.producer.ProducerConfig;
@@ -61,9 +62,9 @@ public class PromotionProducerIntegrationTest {
 
     private KafkaConsumer<String, Promotion> kafkaConsumer() {
         final Properties properties = new Properties();
-        properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaCluster.bootstrapServers());
-        properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringDeserializer.class);
-        properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerialize.class);
+        properties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, kafkaCluster.bootstrapServers());
+        properties.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
+        properties.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, KafkaAvroSerialize.class);
         return new KafkaConsumer<String, Promotion>(properties, new StringDeserializer(), new KafkaAvroDeserialize<>(Promotion.class));
     }