From e4ad4f0633eede7d6234bc02b5902e0330791882 Mon Sep 17 00:00:00 2001 From: Michael Blume Date: Thu, 25 Apr 2013 13:59:31 -0700 Subject: [PATCH] Fix mis-spell in ConsumerConfig.scala --- core/src/main/scala/kafka/consumer/ConsumerConfig.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala index e9cfd100530ff..d32403633ca62 100644 --- a/core/src/main/scala/kafka/consumer/ConsumerConfig.scala +++ b/core/src/main/scala/kafka/consumer/ConsumerConfig.scala @@ -90,7 +90,7 @@ class ConsumerConfig private (val props: VerifiableProperties) extends ZKConfig( /** the socket receive buffer for network requests */ val socketReceiveBufferBytes = props.getInt("socket.receive.buffer.bytes", SocketBufferSize) - /** the number of byes of messages to attempt to fetch */ + /** the number of bytes of messages to attempt to fetch */ val fetchMessageMaxBytes = props.getInt("fetch.message.max.bytes", FetchSize) /** if true, periodically commit to zookeeper the offset of messages already fetched by the consumer */