This is an automated email from the ASF dual-hosted git repository.
jgus pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 97e4583 MINOR: Fix typo in leader epoch change log message (#4476)
97e4583 is described below
commit 97e458342252749d591f4037747668856c63e3a3
Author: Dmitry Minkovsky <[email protected]>
AuthorDate: Fri Jan 26 11:30:47 2018 -0500
MINOR: Fix typo in leader epoch change log message (#4476)
---
core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala
b/core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala
index 2946466..eab0b9c 100644
--- a/core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala
+++ b/core/src/main/scala/kafka/server/epoch/LeaderEpochFileCache.scala
@@ -184,7 +184,7 @@ class LeaderEpochFileCache(topicPartition: TopicPartition,
leo: () => LogOffsetM
checkpoint.write(epochs)
}
- def epochChangeMsg(epoch: Int, offset: Long) = s"New: {epoch:$epoch,
offset:$offset}, Current: {epoch:$latestEpoch, offset$latestOffset} for
Partition: $topicPartition"
+ def epochChangeMsg(epoch: Int, offset: Long) = s"New: {epoch:$epoch,
offset:$offset}, Current: {epoch:$latestEpoch, offset:$latestOffset} for
Partition: $topicPartition"
def validateAndMaybeWarn(epoch: Int, offset: Long) = {
assert(epoch >= 0, s"Received a PartitionLeaderEpoch assignment for an
epoch < 0. This should not happen. ${epochChangeMsg(epoch, offset)}")
--
To stop receiving notification emails like this one, please contact
[email protected].
