Kafka 消费者poll配置
消费者poll消息的细节与消费者心跳配置 长轮询poll消息 默认情况下，消费者⼀次会poll500条消息。 //⼀次poll最⼤拉取消息的条数，可以根据消费速度的快慢来设置 props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 500); 意味着： 如果⼀次poll到500条，就直接执⾏for循环 如果这⼀次没有poll到500条。且时间在1秒内，那么⻓轮询继续poll，要么到500条，要么到1s 如果多次poll都没达到500条，且1秒时间到了，那么直接执⾏for循环 如果两次poll的间隔超过30s，集群会认为该消费者的消费能⼒过弱，该消费者被踢出...
k8s搭建测试kafka
一、安装单节点kafka（自己测试过） 1、创建zookeeper服务 zookeeper-service.yaml内容如下： #Service apiVersion: v1 kind: Service metadata: name: kafka-zookeeper-service labels: name: zookeeper-service spec: selector: name: kafka-zookeeper-pod type: NodePort ports: - name: "zookeeper" port: 2181 targetPort: 2181 zookeeper-deploy.yaml内容如下： #Deployment apiVersion: apps/v1 kind: Deployment metadata...