Incorporated Review comments for the package name.

This commit is contained in:
Amol Gote 2024-03-16 14:56:09 -04:00
parent 2ef61a8884
commit 012020c312
8 changed files with 8 additions and 9 deletions

View File

@ -1,4 +1,4 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
public class Constants {
public static final String MULTI_PARTITION_TOPIC = "multi_partition_topic";

View File

@ -1,4 +1,4 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;

View File

@ -1,4 +1,4 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.config.KafkaListenerEndpointRegistry;

View File

@ -1,4 +1,4 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

View File

@ -1,4 +1,4 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
public class UserEvent {
private String userEventId;

View File

@ -1,4 +1,4 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

View File

@ -1,4 +1,4 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
import org.springframework.stereotype.Component;

View File

@ -1,6 +1,5 @@
package com.baeldung.spring.kafka.start.stop.consumer;
package com.baeldung.spring.kafka.startstopconsumer;
import com.baeldung.spring.kafka.start.stop.consumer.*;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.clients.producer.ProducerRecord;