logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

远程kafka问题并解决 org.apache.kafka.common.errors.TimeoutException: Expiring 4 record(s) for ***0 due to

先检查windows环境上的hosts (C:\Windows\System32\drivers\etc\hosts)是否配置映射 ip与域名的如:192.168.1.100hdp02192.168.1.101 hdp03如果没解决如下查看kafka配置 server.properties.是否有listeners=PLAINTEXT://192.168.1.101:8888advertised.

查看kafka 消费者中消费组的消费情况

查看消费者消费组的消费记录进入kafka目录下的bin目录:./kafka-consumer-offset-checker.sh --zookeeper hdp13.long.com:2181/kafka --group group33 --topic handleMonitorLoggroup消费组topic topic值消费主题pid partition的IDoffsetkafka消费者消费的

kafka面试总结(全面)

Kafka 是一个优秀的分布式消息中间件,许多系统中都会使用到 Kafka 来做消息通信。对分布式消息系统的了解和使用几乎成为一个后台开发人员必备的技能。今天就从常见的 Kafka 面试题入手和大家聊聊 Kafka 的那些事儿。思维导图讲一讲分布式消息中间件面试问题:什么是分布式消息中间件?消息中间件的作用是什么?消息中间件的使用场景是什么?消息中间件选型?消息队列分布式消息是一种通信机制,和 R

#kafka
sparkstreaming 消费kafka kerberos认证报错问题处理

kafka_client_jaas.conf配置参数。spark 参数配置。

文章图片
#kafka#分布式
java.lang.reflect.InvocationTargetException 错误

mysql错误java.lang.reflect.InvocationTargetExceptionat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)at sun.r

到底了