From 304e8519e91a7ebe35474a6a390fe124d6d23b8d Mon Sep 17 00:00:00 2001 From: amrutprabhu Date: Sun, 5 Dec 2021 12:38:38 +0100 Subject: [PATCH] Moving and renaming the plain old kafka communication. --- pom.xml => kafka-plain-old-communication/pom.xml | 0 .../src}/main/java/com/amrut/kafka/consumer/Consumer.java | 0 .../main/java/com/amrut/kafka/consumer/ConsumerAssignAndSeek.java | 0 .../java/com/amrut/kafka/consumer/ConsumerGroupWithThreads.java | 0 .../java/com/amrut/kafka/consumer/ConsumerWithManualCommit.java | 0 .../src}/main/java/com/amrut/kafka/producer/Producer.java | 0 .../com/amrut/kafka/producer/ProducerWithCallbackAndKeys.java | 0 .../java/com/amrut/kafka/producer/ProducerWithHighThroughput.java | 0 .../main/java/com/amrut/kafka/producer/ProducerWithSafety.java | 0 9 files changed, 0 insertions(+), 0 deletions(-) rename pom.xml => kafka-plain-old-communication/pom.xml (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/consumer/Consumer.java (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/consumer/ConsumerAssignAndSeek.java (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/consumer/ConsumerGroupWithThreads.java (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/consumer/ConsumerWithManualCommit.java (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/producer/Producer.java (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/producer/ProducerWithCallbackAndKeys.java (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/producer/ProducerWithHighThroughput.java (100%) rename {src => kafka-plain-old-communication/src}/main/java/com/amrut/kafka/producer/ProducerWithSafety.java (100%) diff --git a/pom.xml b/kafka-plain-old-communication/pom.xml similarity index 100% rename from pom.xml rename to kafka-plain-old-communication/pom.xml diff --git a/src/main/java/com/amrut/kafka/consumer/Consumer.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/Consumer.java similarity index 100% rename from src/main/java/com/amrut/kafka/consumer/Consumer.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/Consumer.java diff --git a/src/main/java/com/amrut/kafka/consumer/ConsumerAssignAndSeek.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/ConsumerAssignAndSeek.java similarity index 100% rename from src/main/java/com/amrut/kafka/consumer/ConsumerAssignAndSeek.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/ConsumerAssignAndSeek.java diff --git a/src/main/java/com/amrut/kafka/consumer/ConsumerGroupWithThreads.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/ConsumerGroupWithThreads.java similarity index 100% rename from src/main/java/com/amrut/kafka/consumer/ConsumerGroupWithThreads.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/ConsumerGroupWithThreads.java diff --git a/src/main/java/com/amrut/kafka/consumer/ConsumerWithManualCommit.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/ConsumerWithManualCommit.java similarity index 100% rename from src/main/java/com/amrut/kafka/consumer/ConsumerWithManualCommit.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/consumer/ConsumerWithManualCommit.java diff --git a/src/main/java/com/amrut/kafka/producer/Producer.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/Producer.java similarity index 100% rename from src/main/java/com/amrut/kafka/producer/Producer.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/Producer.java diff --git a/src/main/java/com/amrut/kafka/producer/ProducerWithCallbackAndKeys.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/ProducerWithCallbackAndKeys.java similarity index 100% rename from src/main/java/com/amrut/kafka/producer/ProducerWithCallbackAndKeys.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/ProducerWithCallbackAndKeys.java diff --git a/src/main/java/com/amrut/kafka/producer/ProducerWithHighThroughput.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/ProducerWithHighThroughput.java similarity index 100% rename from src/main/java/com/amrut/kafka/producer/ProducerWithHighThroughput.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/ProducerWithHighThroughput.java diff --git a/src/main/java/com/amrut/kafka/producer/ProducerWithSafety.java b/kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/ProducerWithSafety.java similarity index 100% rename from src/main/java/com/amrut/kafka/producer/ProducerWithSafety.java rename to kafka-plain-old-communication/src/main/java/com/amrut/kafka/producer/ProducerWithSafety.java