Skip to content

Commit 8b8cc4b

Browse files
committed
(chore) remove useless log
1 parent 5f9a954 commit 8b8cc4b

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

src/main/java/cn/leancloud/kafka/consumer/RebalanceListener.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -28,8 +28,6 @@ final class RebalanceListener<K, V> implements ConsumerRebalanceListener {
2828

2929
@Override
3030
public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
31-
logger.info("Partitions was revoked {}", partitions);
32-
3331
pausedPartitions = consumer.paused();
3432
if (!pausedPartitions.isEmpty()) {
3533
pausedPartitions = new HashSet<>(pausedPartitions);
@@ -39,8 +37,6 @@ public void onPartitionsRevoked(Collection<TopicPartition> partitions) {
3937

4038
@Override
4139
public void onPartitionsAssigned(Collection<TopicPartition> partitions) {
42-
logger.info("Partitions was assigned {}", partitions);
43-
4440
if (!pausedPartitions.isEmpty()) {
4541
final Set<TopicPartition> partitionToPause = partitions
4642
.stream()

0 commit comments

Comments
 (0)