最新最热精华悬赏待回答 筛选
  • 3

    回答

zookeeper启动了但是kafka启动不了

kafka windows下安装 ，zookeeper启动了但是kafka启动不了，端口啥的都没有问题，在命令框输入启动kafka的命令没有反应

回答 吃人陈843
采纳率0%
  • 3

jar运行一段时间后接收不到Kafka数据

我有一个Kafka的消费程序，在测试环境下可以正常运行，然后打包成Jar包准备部署到Linux正式环境进行使用这里发现会出现一个问题，如果使用java -jar xx.jar命令，程序可以正常运行并接

dk_hero
采纳率33.3%
  • 2

golang kafka消费放入main函数启动

type WsChat struct{ LogTag string } func (ws *WsChat) ChatMsgKafkaRead(){ r := kafka.NewRea

showliuzp
采纳率84.3%
  • 3

    回答

idea连接kafka拒绝连接

我在虚拟机上安装了kafka并启动，然后再maven项目里编写了测试文件，显示kafka拒绝连接

回答 Safeties
采纳率0%
  • 5

    回答

jmeter性能测试异常分析

我目前在做iot平台性能测试，测试端到端的响应延时，客户给的需求是100ms以内，我用jmeter模拟mqtt消息发送，此时的mqtt消息体里面是我发送mqtt消息的时间戳，然后我在代码中kafka转

回答 是小杨鸭
采纳率0%
  • 5

    回答

为什么kafka在xsell里面报出警告

就是每次一输入这行我弄蓝色的命令 他就会弹出来警告 这个我们周一就要交了 看看这是怎么回事

  • kafka
  • 6
  • 2025-09-20 09:49
回答 2301_80843961
采纳率0%
  • 4

为什么kafka会有些消息消费不到

遇到一个问题，kafka的消费者设置的批量是200， 生产者发了140条消息，但是消费者在消费批量远远没有达到200的情况下，却消费到了30条消息，而且这30条消息都是实时的，并且没有出现延时，这个是

hezonglin1983
采纳率86%
  • 5

    回答

Kafka节点之间通信失败

Kafka 集群节点之间通信失败 ，我的kafka集群一旦启动就随机有一个节点无法跟其他的节点进行通信。 阿里云 Centos7.9 kafka zookeeper 3.0 通过大模型的推断来解决问

回答 花开自有期,绽放亦有时
采纳率50%
  • 6

kafka-systemctl封装失败

kafka“封装systemctl管理失败” 阿里云-Linux-Centos7.9 通过“通义千问”的推断来排错，但却始终无法找到错误的关键点 我最终想要的是可以通过systemctl来管理的ka

花开自有期,绽放亦有时
采纳率50%
  • 6

    回答

debezium安装遇到的问题

使用debezium连接mysql innodb cluster数据库集群和kafka时候出现了问题连接使用的是kafka connectkafka集群是控制器节点和broker节点分离的方式部署的b

回答 捡垃圾的ITboy
采纳率0%
  • 6

    回答

关于#debezium#的问题，如何解决？(标签-数据库|关键词-connect)

使用debezium连接mysql innodb cluster数据库集群和kafka时候出现了问题连接使用的是kafka connectkafka集群是控制器节点和broker节点分离的方式部署的b

  • kafka
  • 16
  • 2025-06-04 12:20
回答 捡垃圾的ITboy
采纳率0%
  • 4

    回答

kafka数据同步，oracle数据库连接池

服务且接收kafka消息，业务处理后，sql语句修改失败，服务器一直刷新： BEGIN check for expired resources. FINISHED check for expired

回答 chasing鱼
采纳率37.5%
  • 4

    回答

storm启动失败、无法正常启动nimbus

问题遇到的现象和发生背景 背景：在vm虚拟的三台主机上运行storm(1.2.4)、kafka(4.0.0)、zookeeper(3.8.4)问题：启动storm的nimbus、supervisor时

回答 C++的崇拜者
采纳率0%
  • 3

    回答

flink检查点报错

flink的并行度设置为4，kafka分区设置为10，运行2天之后报错如下，请问怎么处理。flink版本是1.12，kafka版本是3.6 java.io.IOException: Could not

回答 Ayingwa
采纳率0%
  • 3

    回答

pyspark连接kafka无解（相关搜索：服务器）

本人尝试用pyspark 连接服务器kafka，尝尽了各种办法，看了所有的aI方法，都是调试不成功，希望会的朋友看看以下代码与报错信息，给予指导，有偿！ ``from pyflink.table im

回答 u014542762
采纳率0%
  • 3

    回答

oracle通过kafka向doris同步数据，json中标记为D的数据没有被删除是什么原因

oracle通过kafka向doris同步数据，json中标记为D的数据没有被删除是什么原因

  • kafka
  • 7
  • 2025-04-28 14:48
回答 young_for you
采纳率0%
  • 3

    回答

kafka问题请求各位劳们！

我用spring boot写了两个kafka消费组，采用kafka Listner可以发现消息通道是没有问题的，但是我这边springboot消费消息比较不稳定，接收不到的概率比较大，另外感觉采用de

回答 2301_76592816
采纳率0%
  • 4

    回答

关于#kafka#的问题：SpringCloudStreamKfka 3.2.7如何指定消费者的 groupid(语言-java)

SpringCloudStreamKfka 3.2.7如何指定消费者的 groupid？ stream: kafka: binder: brok

回答 Ramble_Naylor
采纳率0%
  • 2

    回答

kafka搭建，大数据

大家好，如今在使用虚拟机搭建搭建环境，到了kafka这一步。给大家看一下我们的教程里面的部分3.6 安装Kafka3.6.1 安装// cluster1 上kafka_2.10-0.8.2.1 解压到

回答 ary.风吹我已散
采纳率0%
  • 3

    回答

debezium中文乱码

安装debezium之后，发到kafka的消息query字段的中文是乱码，其他字段的中文正常显示

  • kafka
  • 7
  • 2025-03-21 17:47
回答 逸贤
采纳率0%
  • 5

    回答

flink sql报错

flink 1.19 hive3.1.3版本，从mysql cdc 用kafka向hive同步数据报错，sql没有更新删除操作，并且选了upsert kafka，从插入开始报错。

回答 RainbowUni
采纳率50%
  • 4

kafka实现用户分权

kafka创建两个生产者和两个消费者，实现用户分权，centos7，怎么搞啊？已经安装好java和kafka了

sdrfser
采纳率100%
  • 4

消息队列是什么？面试内容

介绍消息队列的核心原理和实现，以及常见问题及其解决方案等。本文不会过多的扩展详细的消息队列系统，如RocketMQ、RabbitMQ、Kafka等，这些会在后续详细介绍。

好评笔记
采纳率100%
  • 2

    回答

Spring-Kafka在同时使用ErrorHandler和手动提交的情况下，当需要把消息发送到死信队列时，offset该怎么提交？

在spring-kafka中，我们可以使用ErrorHandler来处理错误。通常是重试规定次数后，如果任然报错那么发送到死信队列。现在我希望手动提交offset，手动提交的基本逻辑应该是：如果不报错

回答 qq_34596620
采纳率0%
  • 4

    回答

列出当前 Kafka 集群中所有活跃的 Broker ID报错

在worker1使用docker容器部署的zookeeper，列出当前 Kafka 集群中所有活跃的 Broker ID报错，直接在系统部署的zookeeper则正常，问题出在哪里？难道容器和直接部署

回答 csdn0811
采纳率60.7%
  • 2

    回答

debezium的消息体过大

你好，大神我想问一下，我的dezezium报错org.apache.kafka.common.errors.RecordTooLargeException: The message is 106848

  • kafka
  • 15
  • 2025-01-06 13:45
回答 天才选手马冬冬
采纳率0%
  • 3

    回答

java订阅Kafka数据存入数据库运行七个小时后报内存溢出咋处理

java 订阅Kafka数据存入数据库运行七个小时后报内存溢出咋处理

回答 JSLYYHW
采纳率33.3%
  • 1

    回答

求项目代码和解题思路。

创建Kafka工程项目需要基于IDEA创建新的Kafka工程项目，项目创建规则如下：本次项目创建工具为IDEA，项目类型为Maven，项目名称为：kk-Kafka-Exam本次项目的pom.xml依赖

回答 禾羽510
采纳率0%
  • 1

    回答

使用pycharm用pyspark怎么连接kafka

使用pycharm用pyspark怎么连接kafka文心一言生成的代码 from pyspark.sql import SparkSession # 导入 SparkSession 模块from p

回答 i_ihecaobuxuan
采纳率0%
  • 1

    回答

kafka mirrormaker2支持主题副本数同步吗？

提问，kafka的mirrormaker2是不支持主题的副本数同步吗？mm2的配置文件里面只看到有 远端创建新topic的replication数量设置 replication.factor=3这个配

回答 土豆炕洋芋
采纳率0%