Repository: kafka Updated Branches: refs/heads/trunk d53e99736 -> c82118b19
MINOR: Fix logging in ControlRecordType - typo error corrected (spelling) Author: Kamal C <kamal.chandraprak...@gmail.com> Reviewers: Ismael Juma <ism...@juma.me.uk> Closes #2885 from Kamal15/log Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/c82118b1 Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c82118b1 Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c82118b1 Branch: refs/heads/trunk Commit: c82118b196687cf5f523dfd733bfe575a127c315 Parents: d53e997 Author: Kamal C <kamal.chandraprak...@gmail.com> Authored: Fri Apr 21 14:05:14 2017 +0100 Committer: Ismael Juma <ism...@juma.me.uk> Committed: Fri Apr 21 14:05:14 2017 +0100 ---------------------------------------------------------------------- .../java/org/apache/kafka/common/record/ControlRecordType.java | 4 ++-- .../apache/kafka/common/record/KafkaLZ4BlockOutputStream.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/c82118b1/clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java b/clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java index 723af66..790b2ee 100644 --- a/clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java +++ b/clients/src/main/java/org/apache/kafka/common/record/ControlRecordType.java @@ -72,8 +72,8 @@ public enum ControlRecordType { public static ControlRecordType parse(ByteBuffer key) { short version = key.getShort(0); if (version != CURRENT_CONTROL_RECORD_KEY_VERSION) - log.debug("Received unknown control record key version {}. Parsing as version {}" + - version, CURRENT_CONTROL_RECORD_KEY_VERSION); + log.debug("Received unknown control record key version {}. Parsing as version {}", version, + CURRENT_CONTROL_RECORD_KEY_VERSION); short type = key.getShort(2); switch (type) { case 0: http://git-wip-us.apache.org/repos/asf/kafka/blob/c82118b1/clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java ---------------------------------------------------------------------- diff --git a/clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java b/clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java index 9a100f1..d029489 100644 --- a/clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java +++ b/clients/src/main/java/org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java @@ -258,7 +258,7 @@ public final class KafkaLZ4BlockOutputStream extends FilterOutputStream { @Override public void close() throws IOException { if (!finished) { - // basicallly flush the buffer writing the last block + // basically flush the buffer writing the last block writeBlock(); // write the end block and finish the stream writeEndMark();
