Permalink
Browse files

Fixing compilation issues on SimpleKafkaStreamDataProvider. Now using…

… slf4j, instead of log4j directly.
  • Loading branch information...
1 parent 77beaea commit d3c3e4f434e8dfcae72081b61fddd092d03e82af @alejandroperez alejandroperez committed Nov 7, 2012
@@ -30,7 +30,7 @@
</plugin>
<plugin>
<artifactId>maven-resources-plugin</artifactId>
- <version>2.2</version>
+ <version>2.4</version>
<configuration>
<encoding>UTF-8</encoding>
</configuration>
@@ -110,5 +110,9 @@
<groupId>org.apache.derby</groupId>
<artifactId>derby</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ </dependency>
</dependencies>
</project>
@@ -28,7 +28,8 @@
import kafka.message.ByteBufferMessageSet;
import kafka.message.MessageAndOffset;
-import org.apache.log4j.Logger;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import org.json.JSONObject;
import proj.zoie.api.DataConsumer.DataEvent;
@@ -46,7 +47,7 @@
private Iterator<MessageAndOffset> _msgIter;
private ThreadLocal<byte[]> bytesFactory;
- private static Logger logger = Logger.getLogger(KafkaStreamDataProvider.class);
+ private static Logger logger = LoggerFactory.getLogger(KafkaStreamDataProvider.class);
public static final int DEFAULT_MAX_MSG_SIZE = 5*1024*1024;
private final String _kafkaHost;

0 comments on commit d3c3e4f

Please sign in to comment.