String clientId
发出请求时传递给服务器的id字符串。设置该值的目的是方便在服务器端请求日志中包含逻辑应用程序名称,从而能够跟踪ip/端口之外的请求源。该值可以设置为应用名称。
ConsumerCoordinator coordinator
消费协调器,后续会详细介绍。
Deserializer< K> keyDeserializer
key 序列化器。
Deserializer< V> valueDeserializer
值序列化器。
ConsumerNetworkClient client
网络通讯客户端。
SubscriptionState subscriptions
用于管理订阅状态的类,用于跟踪 topics, partitions, offsets 等信息。后续会详细介绍。
ConsumerMetadata metadata
消费者元数据信息,包含路由信息。
long retryBackoffMs
如果向 broker 发送请求失败后,发起重试之前需要等待的间隔时间,通过属性 retry.backoff.ms 指定。
long requestTimeoutMs
一次请求的超时时间。
int defaultApiTimeoutMs
为所有可能阻塞的API设置一个默认的超时时间。
List< PartitionAssignor> assignors
分区分配算法(分区负载算法)。
Kafka Consumer 消费者就介绍到这里了,从下篇文章开始将开始详细介绍 Kafka 关于消息消费的方方面面。
作者介绍:
丁威,《RocketMQ技术内幕》作者,RocketMQ 社区布道师,公众号:中间件兴趣圈 维护者,目前已陆续发表源码分析Java集合、Java 并发包(JUC)、Netty、Mycat、Dubbo、RocketMQ、Mybatis等源码专栏。欢迎加入我的知识星球,构建一个高质量的技术交流社群。