From df2e8629eb95440f4db266c50a2552786779a625 Mon Sep 17 00:00:00 2001 From: Yaguo Zhou Date: Mon, 16 Feb 2015 14:56:49 +0800 Subject: [PATCH] fix typo: SO_SNDBUFF -> SO_SNDBUF, SO_RCVBUFF -> SO_RCVBUF --- core/src/main/scala/kafka/server/KafkaConfig.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala index 6d74983..14bf321 100644 --- a/core/src/main/scala/kafka/server/KafkaConfig.scala +++ b/core/src/main/scala/kafka/server/KafkaConfig.scala @@ -117,10 +117,10 @@ class KafkaConfig private (val props: VerifiableProperties) extends ZKConfig(pro * it will publish the same port that the broker binds to. */ val advertisedPort: Int = props.getInt("advertised.port", port) - /* the SO_SNDBUFF buffer of the socket sever sockets */ + /* the SO_SNDBUF buffer of the socket sever sockets */ val socketSendBufferBytes: Int = props.getInt("socket.send.buffer.bytes", 100*1024) - /* the SO_RCVBUFF buffer of the socket sever sockets */ + /* the SO_RCVBUF buffer of the socket sever sockets */ val socketReceiveBufferBytes: Int = props.getInt("socket.receive.buffer.bytes", 100*1024) /* the maximum number of bytes in a socket request */ -- 2.1.2