root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

rename produce to produces (#9811) 

Co-authored-by: 沈文兵 <shenwenbing@qianxin.com>

reviewers: Boyang Chen <boyang@confluent.io>
This commit is contained in:
wenbingshen 2021-01-04 13:20:48 +08:00 committed by GitHub
parent 2515bf2368
commit 0eea5845c5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/scala/kafka/network/SocketServer.scala
View File

@ -71,7 +71,7 @@ import scala.util.control.ControlThrowable
* - The threading model is * - The threading model is
* 1 Acceptor thread that handles new connections * 1 Acceptor thread that handles new connections
* Acceptor has 1 Processor thread that has its own selector and read requests from the socket. * Acceptor has 1 Processor thread that has its own selector and read requests from the socket.
* 1 Handler thread that handles requests and produce responses back to the processor thread for writing. * 1 Handler thread that handles requests and produces responses back to the processor thread for writing.
*/ */
class SocketServer(val config: KafkaConfig, class SocketServer(val config: KafkaConfig,
val metrics: Metrics, val metrics: Metrics,