Skip to content

Commit a31a7aa

Browse files
author
Boris Shkolnik
committed
reduce debugging from info to debug in KafkaCheckpointManager.java
1 parent c93dd8f commit a31a7aa

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ class KafkaCheckpointManager(
103103

104104
systemProducer.send(taskName.getTaskName, envelope)
105105
systemProducer.flush(taskName.getTaskName) // make sure it is written
106-
info("Completed writing checkpoint=%s into %s topic for system %s." format(checkpoint, checkpointTopic, systemName) )
106+
debug("Completed writing checkpoint=%s into %s topic for system %s." format(checkpoint, checkpointTopic, systemName) )
107107
loop.done
108108
},
109109

0 commit comments

Comments
 (0)