Skip to content

Commit

Permalink
Fix mis-spell in ConsumerConfig.scala
Browse files Browse the repository at this point in the history
  • Loading branch information
Michael Blume committed Apr 25, 2013
1 parent 731ba90 commit e4ad4f0
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion core/src/main/scala/kafka/consumer/ConsumerConfig.scala
Original file line number Diff line number Diff line change
Expand Up @@ -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 */
Expand Down

0 comments on commit e4ad4f0

Please sign in to comment.