Browse Source

refactor packages

Grega Bremec 7 months ago
parent
commit
a4618ef949

+ 3 - 3
sample-stream/pom.xml

@@ -51,7 +51,7 @@
                     </execution>
                 </executions>
                 <configuration>
-                    <mainClass>com.redhat.training.kafka.SimpleStream</mainClass>
+                    <mainClass>com.redhat.training.kafka.coreapi.streams.SimpleStream</mainClass>
                 </configuration>
             </plugin>
         </plugins>
@@ -78,7 +78,7 @@
                             </execution>
                         </executions>
                         <configuration>
-                            <mainClass>com.redhat.training.kafka.RandomPaymentProducer</mainClass>
+                            <mainClass>com.redhat.training.kafka.coreapi.RandomPaymentProducer</mainClass>
                         </configuration>
                     </plugin>
                 </plugins>
@@ -105,7 +105,7 @@
                             </execution>
                         </executions>
                         <configuration>
-                            <mainClass>com.redhat.training.kafka.LargePaymentConsumer</mainClass>
+                            <mainClass>com.redhat.training.kafka.coreapi.LargePaymentConsumer</mainClass>
                         </configuration>
                     </plugin>
                 </plugins>

+ 1 - 1
sample-stream/src/main/java/com/redhat/training/kafka/LargePaymentConsumer.java → sample-stream/src/main/java/com/redhat/training/kafka/coreapi/LargePaymentConsumer.java

@@ -1,4 +1,4 @@
-package com.redhat.training.kafka;
+package com.redhat.training.kafka.coreapi;
 
 import java.time.Duration;
 import java.util.Collections;

+ 1 - 1
sample-stream/src/main/java/com/redhat/training/kafka/RandomPaymentProducer.java → sample-stream/src/main/java/com/redhat/training/kafka/coreapi/RandomPaymentProducer.java

@@ -1,4 +1,4 @@
-package com.redhat.training.kafka;
+package com.redhat.training.kafka.coreapi;
 
 import java.util.Properties;
 import java.util.Random;

+ 1 - 1
sample-stream/src/main/java/com/redhat/training/kafka/SimpleStream.java → sample-stream/src/main/java/com/redhat/training/kafka/coreapi/streams/SimpleStream.java

@@ -1,4 +1,4 @@
-package com.redhat.training.kafka;
+package com.redhat.training.kafka.coreapi.streams;
 
 import java.util.Map;
 import java.util.Properties;