BAEL-7374 - Review comments.
This commit is contained in:
parent
a40222a45a
commit
0a2d6823de
@ -1,8 +1,6 @@
|
|||||||
package com.baeldung.spring.kafka.start.stop.consumer;
|
package com.baeldung.spring.kafka.start.stop.consumer;
|
||||||
|
|
||||||
public class Constants {
|
public class Constants {
|
||||||
|
|
||||||
public static final String MULTI_PARTITION_TOPIC = "multi_partition_topic";
|
public static final String MULTI_PARTITION_TOPIC = "multi_partition_topic";
|
||||||
|
|
||||||
public static final String LISTENER_ID = "listener-id-1";
|
public static final String LISTENER_ID = "listener-id-1";
|
||||||
}
|
}
|
||||||
|
@ -5,9 +5,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
|
|||||||
|
|
||||||
@SpringBootApplication
|
@SpringBootApplication
|
||||||
public class StartStopConsumerApplication {
|
public class StartStopConsumerApplication {
|
||||||
|
|
||||||
public static void main(String[] args) {
|
public static void main(String[] args) {
|
||||||
SpringApplication.run(StartStopConsumerApplication.class, args);
|
SpringApplication.run(StartStopConsumerApplication.class, args);
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
@ -1,10 +1,8 @@
|
|||||||
package com.baeldung.spring.kafka.start.stop.consumer;
|
package com.baeldung.spring.kafka.start.stop.consumer;
|
||||||
|
|
||||||
public class UserEvent {
|
public class UserEvent {
|
||||||
|
|
||||||
private String userEventId;
|
private String userEventId;
|
||||||
|
|
||||||
|
|
||||||
public UserEvent() {
|
public UserEvent() {
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -19,5 +17,4 @@ public class UserEvent {
|
|||||||
public void setUserEventId(String userEventId) {
|
public void setUserEventId(String userEventId) {
|
||||||
this.userEventId = userEventId;
|
this.userEventId = userEventId;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user