Repository: samza Updated Branches: refs/heads/NewKafkaSystemConsumer [created] 361596317
reduce debugging from info to debug in KafkaCheckpointManager.java Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/a31a7aa2 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/a31a7aa2 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/a31a7aa2 Branch: refs/heads/NewKafkaSystemConsumer Commit: a31a7aa29b7be4bb46f8e651b6b8fa46a65b48e2 Parents: c93dd8f Author: Boris Shkolnik <[email protected]> Authored: Mon Oct 16 15:25:49 2017 -0700 Committer: Boris Shkolnik <[email protected]> Committed: Mon Oct 16 15:25:49 2017 -0700 ---------------------------------------------------------------------- .../org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/a31a7aa2/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala ---------------------------------------------------------------------- diff --git a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala index 4eb6666..b016b4a 100644 --- a/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala +++ b/samza-kafka/src/main/scala/org/apache/samza/checkpoint/kafka/KafkaCheckpointManager.scala @@ -103,7 +103,7 @@ class KafkaCheckpointManager( systemProducer.send(taskName.getTaskName, envelope) systemProducer.flush(taskName.getTaskName) // make sure it is written - info("Completed writing checkpoint=%s into %s topic for system %s." format(checkpoint, checkpointTopic, systemName) ) + debug("Completed writing checkpoint=%s into %s topic for system %s." format(checkpoint, checkpointTopic, systemName) ) loop.done },
