diff --git a/.classpath b/.classpath
index b795db8..c796a55 100644
--- a/.classpath
+++ b/.classpath
@@ -12,12 +12,12 @@
-
+
-
+
diff --git a/.settings/org.eclipse.jdt.core.prefs b/.settings/org.eclipse.jdt.core.prefs
index 01a09ff..7ccb20f 100644
--- a/.settings/org.eclipse.jdt.core.prefs
+++ b/.settings/org.eclipse.jdt.core.prefs
@@ -6,9 +6,9 @@ org.eclipse.jdt.core.compiler.annotation.nonnullbydefault=org.eclipse.jdt.annota
org.eclipse.jdt.core.compiler.annotation.nullable=org.eclipse.jdt.annotation.Nullable
org.eclipse.jdt.core.compiler.annotation.nullanalysis=disabled
org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
-org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.7
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.6
org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
-org.eclipse.jdt.core.compiler.compliance=1.7
+org.eclipse.jdt.core.compiler.compliance=1.6
org.eclipse.jdt.core.compiler.debug.lineNumber=generate
org.eclipse.jdt.core.compiler.debug.localVariable=generate
org.eclipse.jdt.core.compiler.debug.sourceFile=generate
@@ -96,4 +96,4 @@ org.eclipse.jdt.core.compiler.problem.unusedPrivateMember=warning
org.eclipse.jdt.core.compiler.problem.unusedTypeParameter=ignore
org.eclipse.jdt.core.compiler.problem.unusedWarningToken=warning
org.eclipse.jdt.core.compiler.problem.varargsArgumentNeedCast=warning
-org.eclipse.jdt.core.compiler.source=1.7
+org.eclipse.jdt.core.compiler.source=1.6
diff --git a/pom.xml b/pom.xml
index 5889e5d..874b38f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -29,6 +29,31 @@
+
+ maven-compiler-plugin
+ 2.3.2
+
+
+ default-testCompile
+ test-compile
+
+ testCompile
+
+
+
+ default-compile
+ compile
+
+ compile
+
+
+
+
+
+ 1.6
+
+
+
maven-jar-plugin
2.4
diff --git a/src/jvm/storm/kafka/bolt/KafkaBolt.java b/src/jvm/storm/kafka/bolt/KafkaBolt.java
index f3e655e..778bfdc 100644
--- a/src/jvm/storm/kafka/bolt/KafkaBolt.java
+++ b/src/jvm/storm/kafka/bolt/KafkaBolt.java
@@ -67,7 +67,7 @@ public void execute(Tuple input) {
}
V message = (V) input.getValueByField(BOLT_MESSAGE);
try {
- LOG.debug(String.format("Sending message to topic %s with key %s", topic, key));
+ LOG.info(String.format("Sending message to topic %s with key %s", topic, key));
producer.send(new KeyedMessage(topic, key, message));
} catch (Exception ex) {
LOG.error("Could not send message with key '" + key + "' and value '" + message + "'", ex);