Replace Deprecated Calls

src/main/java/datawave/microservice/query/messaging/kafka/KafkaQueryResultsListener.java

@@ -4,6 +4,7 @@
 import static datawave.microservice.query.messaging.AcknowledgementCallback.Status.NACK;
 import static datawave.microservice.query.messaging.kafka.KafkaQueryResultsManager.TOPIC_PREFIX;
 
+import java.time.Duration;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
@@ -154,7 +155,7 @@ public void onMessage(ConsumerRecord<String,String> data, final Acknowledgment a
                     latch.countDown();
                 });
             } catch (JsonProcessingException e) {
-                acknowledgment.nack(0);
+                acknowledgment.nack(Duration.ofNanos(0));
                 if (log.isTraceEnabled()) {
                     log.trace("Query {} Nacking record from topic {} and partition {} at offset {} because the result could not be deserialized", queryId,
                                     data.topic(), data.partition(), data.offset());
@@ -181,21 +182,21 @@ public void onMessage(ConsumerRecord<String,String> data, final Acknowledgment a
                                         data.offset());
                     }
                 } else if (ackStatus.get() == NACK) {
-                    acknowledgment.nack(0);
+                    acknowledgment.nack(Duration.ofNanos(0));
                     if (log.isTraceEnabled()) {
                         log.trace("Query {} Nacking record {} from topic {} and partition {} at offset {} because the record was rejected", queryId, resultId,
                                         data.topic(), data.partition(), data.offset());
                     }
                 }
             } catch (InterruptedException ie) {
-                acknowledgment.nack(0);
+                acknowledgment.nack(Duration.ofNanos(0));
                 if (log.isTraceEnabled()) {
                     log.trace("Query {} Nacking record {} from topic {} and partition {} at offset {} because the latch was interrupted", queryId, resultId,
                                     data.topic(), data.partition(), data.offset());
                 }
             }
         } else {
-            acknowledgment.nack(0);
+            acknowledgment.nack(Duration.ofNanos(0));
             if (log.isTraceEnabled()) {
                 log.trace("Query {} Nacking record from topic {} and partition {} at offset {} because the container was stopped", queryId, data.topic(),
                                 data.partition(), data.offset());

src/main/java/datawave/microservice/query/messaging/kafka/KafkaQueryResultsManager.java

@@ -192,7 +192,7 @@ private TopicDescription describeTopic(String topic) {
             // @formatter:off
             topicDesc = adminClient
                     .describeTopics(Collections.singleton(topic))
-                    .values()
+                    .topicNameValues()
                     .get(topic)
                     .get();
             // @formatter:on

src/main/java/datawave/microservice/query/messaging/rabbitmq/config/RabbitMQMessagingConfiguration.java

@@ -66,8 +66,6 @@ public CachingConnectionFactory createCachingConnectionFactory(MessagingProperti
                 finalConnectionFactory.setPublisherConfirmType(rabbitMqProperties.getPublisherConfirmType());
             }
 
-            finalConnectionFactory.setPublisherConfirms(CachingConnectionFactory.ConfirmType.SIMPLE != rabbitMqProperties.getPublisherConfirmType()
-                            && rabbitMqProperties.isPublisherConfirms());
             finalConnectionFactory.setPublisherReturns(rabbitMqProperties.isPublisherReturns());
         }
         return finalConnectionFactory;