You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gw...@apache.org on 2015/12/23 03:30:42 UTC
kafka git commit: MINOR: Fix a typos in comments
Repository: kafka
Updated Branches:
refs/heads/trunk 07ee17fd0 -> 83d4c359b
MINOR: Fix a typos in comments
Author: ouyangliduo <ou...@360.cn>
Reviewers: Gwen Shapira, Lin Dong
Closes #701 from oyld/typos_fix
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/83d4c359
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/83d4c359
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/83d4c359
Branch: refs/heads/trunk
Commit: 83d4c359bab40ce7418cd5f7219a23a9fcfba921
Parents: 07ee17f
Author: ouyangliduo <ou...@360.cn>
Authored: Tue Dec 22 18:30:38 2015 -0800
Committer: Gwen Shapira <cs...@gmail.com>
Committed: Tue Dec 22 18:30:38 2015 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/83d4c359/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala b/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
index e502d38..00f3275 100644
--- a/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
+++ b/core/src/main/scala/kafka/coordinator/GroupMetadataManager.scala
@@ -564,7 +564,7 @@ class GroupMetadataManager(val brokerId: Int,
trace("Marked %d offsets in %s for deletion.".format(messages.size, appendPartition))
try {
- // do not need to require acks since even if the tombsone is lost,
+ // do not need to require acks since even if the tombstone is lost,
// it will be appended again in the next purge cycle
partition.appendMessagesToLeader(new ByteBufferMessageSet(config.offsetsTopicCompressionCodec, messages: _*))
tombstones.size