排查到的原因 配置的IP跟host 不对 错误排查： 服务器防火墙已关闭，本地telnet连接9092端口没问题 kafka配置文件 listeners=PLAINTEXT://{内网ip}:9092 将项目日志级别调制 ...

windows下使用kafka遇到这个问题: Error when sending message to topic test with key: null, value: 2 bytes with error ...

我的kafka是CDH上的2.11版本 在linux客户端启动了kafka自带的producer 和consumer后能正常生产和消费 但是， 在idea启动了自定义的生产者向kafka发送数据的时候报： 并且开启消费者后看不到数据，说明生产者发送数据失败 有人说： 修改 ...

今天居然碰到这个错误，参考以下解决方案： 修改server.properties，然后将每个节点的kafka重启即可解决。 查看集群是否有broker没有运行 ...

在做支付订单宽表的场景，需要关联的表比较多而且支付有可能要延迟很久，这种情况下不太适合使用Flink的表Join，想到的另外一种解决方案是消费多个Topic的数据，再根据订单号进行keyBy,再在逻辑中根据不同Topic处理，所以在接收到的消息中最好能够有topic字段 ...

项目名称：布控预警 水平拆分出来的项目，作为一个单独的可以对外提供服务的项目 项目设计：springcloud，可以集成各个不同平台的一个作为对外提供的微服务项目 项目功能：实现各个平台和本平台之间的布控（对人员和摄像头进行和厂商对接可以进行实时抓拍）和预警（厂商抓拍到之后实时通知给本平台 ...

环境： Windows 10, Ubuntu 18.04 （虚拟机） Java 8 Spring Boot 2.5.2，其下的 spring-kafka 版本 2.7.3，kafka-streams 版本 2.7.1 apache-zookeeper-3.7.0，单机 ...

参照我之前的一篇博文Kafka学习之（二）Centos下安装Kafka安装了kafka并启动，状况并不像我之前最初的预期，报错了，并且我在当前Linux环境下安装的Java版本、Kafka版本都是和之前博文一样的，第一感觉难道是因为Linux(Centos)的版本不一致？？？ 抛开猜测，直接 ...