ProducerImpl {代码...} grabCnx() {代码...} client.getConnection(topic) {代码...} lookup.getBroker(destinationName) {代码...} 请求 {代码...} 返回 {代码...}

client处理逻辑 ConnectionPool netty相关配置在com.yahoo.pulsar.client.impl.ConnectionPool {代码...} messageReceived方法 {代码...} 消息未压缩大小超过限制直接丢弃 {代码...} discardCorruptedMessage {代码...} 接收消息到incomingMessages(BlockingQueue<Message> ) 在配置文件指定queue的大小，或者使用...

standalone模式 {代码...} maven {代码...} producer {代码...} consumer {代码...} docs pulsar-GettingStarted