consumer worker rename

src/main/java/com/tsi/comm/consumer/kafka/KafkaConsumerService.java

@@ -47,7 +47,7 @@ public class KafkaConsumerService {
         containerProperties.setGroupId(this.groupId);
         containerProperties.setPollTimeout(5000);
         //containerProperties.setAckMode(ContainerProperties.AckMode.MANUAL);
-        containerProperties.setMessageListener(new TsiKafkaConsumerWorker(consumerTopic, keys));
+        containerProperties.setMessageListener(new KafkaConsumerWorker(consumerTopic, keys));
         containerProperties.setConsumerRebalanceListener(new ConsumerAwareRebalanceListener() {
             @Override
             public void onPartitionsRevokedBeforeCommit(Consumer<?, ?> consumer, Collection<TopicPartition> partitions) {

src/main/java/com/tsi/comm/consumer/kafka/TsiKafkaConsumerWorker.java → src/main/java/com/tsi/comm/consumer/kafka/KafkaConsumerWorker.java

@@ -12,7 +12,7 @@ import java.util.HashSet;
 
 @Slf4j
 @AllArgsConstructor
-public class TsiKafkaConsumerWorker implements MessageListener<String, byte[]> {
+public class KafkaConsumerWorker implements MessageListener<String, byte[]> {
 
     private final String topic;
     private final HashSet<String> keyValues;