From 9a3164f087cfc7c64cb7ba076734376b9d4cd2ab Mon Sep 17 00:00:00 2001
From: Sahil Palvia <spalvia1990@gmail.com>
Date: Mon, 19 Mar 2018 11:17:56 -0700
Subject: [PATCH] Removing CommonsLog and replacing it wil Slf4j. (#318)

---
 .../kinesis/retrieval/SimpleRecordsFetcherFactory.java |  6 +++---
 .../PrefetchGetRecordsCacheIntegrationTest.java        | 10 +++++-----
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/SimpleRecordsFetcherFactory.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/SimpleRecordsFetcherFactory.java
index 37e6026b..067c8f19 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/SimpleRecordsFetcherFactory.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/retrieval/SimpleRecordsFetcherFactory.java
@@ -16,12 +16,12 @@ package software.amazon.kinesis.retrieval;
 
 import java.util.concurrent.Executors;
 
-import software.amazon.kinesis.metrics.IMetricsFactory;
 import com.google.common.util.concurrent.ThreadFactoryBuilder;
 
-import lombok.extern.apachecommons.CommonsLog;
+import lombok.extern.slf4j.Slf4j;
+import software.amazon.kinesis.metrics.IMetricsFactory;
 
-@CommonsLog
+@Slf4j
 public class SimpleRecordsFetcherFactory implements RecordsFetcherFactory {
     private int maxPendingProcessRecordsInput = 3;
     private int maxByteSize = 8 * 1024 * 1024;
diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/PrefetchGetRecordsCacheIntegrationTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/PrefetchGetRecordsCacheIntegrationTest.java
index 4f5fe955..6b1136fe 100644
--- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/PrefetchGetRecordsCacheIntegrationTest.java
+++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/retrieval/PrefetchGetRecordsCacheIntegrationTest.java
@@ -33,7 +33,6 @@ import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
-import software.amazon.kinesis.leases.ShardInfo;
 import org.junit.After;
 import org.junit.Before;
 import org.junit.Test;
@@ -43,19 +42,20 @@ import org.mockito.invocation.InvocationOnMock;
 import org.mockito.runners.MockitoJUnitRunner;
 import org.mockito.stubbing.Answer;
 
-import software.amazon.kinesis.lifecycle.ProcessRecordsInput;
-import software.amazon.kinesis.metrics.NullMetricsFactory;
 import com.amazonaws.services.kinesis.model.ExpiredIteratorException;
 import com.amazonaws.services.kinesis.model.GetRecordsResult;
 import com.amazonaws.services.kinesis.model.Record;
 
-import lombok.extern.apachecommons.CommonsLog;
+import lombok.extern.slf4j.Slf4j;
+import software.amazon.kinesis.leases.ShardInfo;
+import software.amazon.kinesis.lifecycle.ProcessRecordsInput;
+import software.amazon.kinesis.metrics.NullMetricsFactory;
 
 /**
  * These are the integration tests for the PrefetchGetRecordsCache class. 
  */
 @RunWith(MockitoJUnitRunner.class)
-@CommonsLog
+@Slf4j
 public class PrefetchGetRecordsCacheIntegrationTest {
     private static final int MAX_SIZE = 3;
     private static final int MAX_BYTE_SIZE = 5 * 1024 * 1024;