• 全部
  • 关注
  • 有问必答
  • 等你来答

排行榜

  • 用户榜
  • 标签榜
  • 冲榜分奖金

频道

  • 编程语言
  • 前端
  • Java
  • Python
  • 大数据
  • 人工智能
  • 数据结构与算法
  • 嵌入式
  • 其他
  • 运维
  • 网络
  • 服务器
  • 移动开发
  • 后端
  • 开发工具
  • 微软技术
  • 硬件开发
  • 游戏
  • 吐槽问答
  • 测试
  • 小程序
  • 高考
  • PHP
  • 安全
  • 云计算
  • 开放平台
  • 软件工程
  • 设计
  • 职场和发展
  • 区块链
  • 多彩生活
  • 产品/运营
  • HarmonyOS
  • 搜索
  • 设计模式
最新最热精华悬赏待回答 筛选
  • 5

    回答

prometheus监控kafka的问题

操作环境、软件版本等信息prometheus-2.36.0.linux-amd64alertmanager-0.24.0.linux-amd64blackbox_exporter-0.21.0.lin

回答 kc32668287
采纳率33.3%
  • 1

    回答

kfaka的问题应该是

kafka stream started!2022-06-17 07:48:28,218 WARN --- [ StreamT

  • kafka
  • 11
  • 2022-06-17 08:02
回答 耿晔业
采纳率0%
  • 1

    回答

kafka可以生产无法消费的问题

问题遇到的现象和发生背景 我用java代码，已经实现了生产消息到kafka,用桌面工具查询是添加上的，kafka也在我本地创建的，但是消费时候poll的数据条数始终为0 问题相关代码 import o

回答 克伦留索夫
采纳率75%
  • 1

    回答

Docker启动kafka问题

【请教】Docker启动kafka问题 请教个问题，尝试用docker安装kafka，现在无法进入容器问题。一直是bash5.1，不是容器。 以下是配置及日志， 请指教，谢谢

  • kafka
  • 7
  • 2022-06-07 23:13
回答 Java程序猿小肉咩
采纳率0%
  • 1

    回答

mq相关问题，消费者向指定分区获取消息

1.使用消息中间件，拿kafka举例，生产者向指定partition投放消息，然后消费者在指定分区中拿消息，这合理吗？比如csdn系统消息，我修改了个人的资料，然后点击消息标签，进入消息展示页面，出现

回答 LinZP101
采纳率66.7%
  • 1

    回答

把文本文档中的数据传送到kafka中

通过Python爬取的数据存入到文本文档中，然后如何才能实现数据传送到kafka中

回答 qq_49063424
采纳率0%
  • 2

    回答

hdfs sink报错

问题遇到的现象和发生背景 flume hdfs sink 同步kafka主题诗句到hdfs总出错误 问题相关代码，请勿粘贴截图 flume配置文件 ## 组件 a1.sources=r1 a1.cha

回答 liulishc
采纳率0%
  • 2

    回答

kafka创建主题错误

问题遇到的现象和发生背景 问题相关代码，请勿粘贴截图 kafka-topics.sh --create --zookeeper bigdata:2181 --topic zhangsan --pa

回答 qq_58579963
采纳率0%
  • 1

编写一个生产者程序mysql_producer.py:

正在学，代码是给的kafka也打开了from kafka import KafkaProducerimport jsonimport pymysql.cursors producer = KafkaP

tutou99precent
采纳率100%
  • 2

    回答

windows启动kafka输入命令后没有反应

已经成功启动了zookeeper，但是启动kafka后输入命令没有反应，截图如下： 配置文件也是修改了的 zookeeper的： kafka的： 我想要达到的结果 我只是想在windows上启动

  • ¥5
  • kafka
  • 30
  • 2022-05-16 23:09
路漫远
采纳率25%
  • 1

在win10启动kafka报错

问题遇到的现象和发生背景 已经启动zookeeper 问题相关代码，请勿粘贴截图 ```bash D:\ideaworks\kafka_2.11-0.11.0.2>.\bin\windows\

zqy518518
采纳率62.5%
  • 1

    回答

flink流写入数据到oracle非常慢，，还不如java

问题遇到的现象和发生背景 flink流写入oracle非常慢，因为流写入使用的是自定的sinkFunction,所以也是用的jdbc,但是效率还不如java效率高 问题相关代码，请勿粘贴截图 ps =

回答 nicodeme
采纳率0%
  • 2

    回答

数据由kafka出来经过flink加工，但是入不了hive

问题遇到的现象和发生背景 我的数据从卡夫卡出来，复杂的json格式，里面含list，我在flink中用stream加工后，存入临时view，然后想通过sql-api插入hive，程序不报错，但就是数据

回答 追而不得
采纳率0%
  • 1

    回答

kafka顺序写的疑问

即使一个segment是追加，那多个分区的segment都要写磁盘啊。而且多个分区的消息可能是交叉进来的，磁头不还是得移动，那kafka是怎么保证顺序写磁盘的呢

回答 wujing_csdn
采纳率0%
  • 1

这两个依赖有啥区别呢？？

如图，这两个依赖有什么区别，消费者该用哪个？（不要管后面的：为什么不足30字符就不能问？这是什么脑残设定？问题一定会有很多字?不知道言简意赅这个词？）

上酱潘凤
采纳率50%
  • 1

    回答

怎么从数据库把数据导入到kafka 的消息队列

怎么把mysql数据库的数据传到KAFKA集群里面，并且消费者消费到数据。

回答 授之以渔y
采纳率0%
  • 2

    回答

Spark Structured Streaming 时间窗口 不能输出数据

问题遇到的现象和发生背景 Spark Structured Streaming 环境接收 kafka 数据 进行处理 然后Append 模式 输出到控制台 问题相关代码，请勿粘贴截图 设置 wat

大_G
采纳率50%
  • 4

    回答

对接kakfa kerbro认证报 Connection to node -1

对接kakfa kerbro认证报 Connection to node -1 terminated during authentication. This may indicate that aut

琴树与吉娜
采纳率0%
  • 1

    回答

kafka103，104机器启动失败

问题遇到的现象和发生背景 按照教程配置的 问题相关代码，请勿粘贴截图 运行结果及报错内容 我的解答思路和尝试过的方法 我想要达到的结果

回答 qq_38431690
采纳率81.8%
  • 1

    回答

kafka自动停止并且启动不了

[2022-03-20 18:22:00,978] INFO Session establishment complete on server zookeeper/172.17.0.3:2181, s

回答 Zwen14
采纳率0%
  • 8

    回答

kafka连接中断在日志中打印出连接失败信息

想要在网络原因或者ip问题导致的连接失败或者超时时，在日志中打印出kafka连接失败的提示信息如何去处理，希望有懂得给一个明确的回答，两天内有效

SYD19970128
采纳率0%
  • 1

    回答

kafka中出现：No type information in headers and no default type provided

kafka中突然报了No type information in headers and no default type provided 相关代码 @KafkaListener(contai

  • kafka
  • 43
  • 2022-03-20 14:23
回答 毕业即失业吗
采纳率0%
  • 2

    回答

idm出问题了，求解决

为什么这样，能不能帮我看一下，看一下这个idm，帮帮忙看看这个

回答 m0_67698179
采纳率0%
  • 2

    回答

kafka提交报错，希望能得到解决

一：背景手动poll kafka消息，并且手动提交； 运行的时候，偶尔（频次比较低）会出现如下错误：org.apache.kafka.clients.consumer.RetriableCommitF

  • ¥5
  • kafka
  • 45
  • 2022-03-11 14:05
独家记忆shine
采纳率50%
  • 4

    回答

kafka 出现 ERROR Error during poll on topic test SQL

问题遇到的现象和发生背景 kafka-connect-oracle 获取 oracle12c cdc 时 问题相关代码，请勿粘贴截图 运行结果及报错内容 [root@cyrus kafka]# ./

m0_37994675
采纳率25%
  • 1

    回答

kafka 链接oracle 报错 operation not allowed from within a pluggable database

问题遇到的现象和发生背景 kafka 链接oracle 问题相关代码，请勿粘贴截图 [2022-03-10 16:52:21,287] ERROR Task is being killed and

回答 m0_37994675
采纳率25%
  • 1

    回答

求-kafka客户端发送异常：Topic topic-demo03 not present in metadata after 60000 ms

问题遇到的现象和发生背景 三台机器部署了zookeeper、kafka集群，都成功启动，打开终端，创建topic，成功,查看topic信息，正常 [root@node2 ~]$ kafka-topic

回答 weixin_42506330
采纳率50%
  • 1

    回答

spring项目写完kafka起不来项目

问题遇到的现象和发生背景 问题相关代码，请勿粘贴截图 运行结果及报错内容 [2022-02-25 11:42:04,064][ERROR] org.springframework.web.contex

回答 Java开发从入门到入土
采纳率0%
  • 1

    回答

fakfa分区数和消费者数量一致，分配不均衡，一个消费者消费多个分区

**配置情况：kafka中broker节点3个，partition 为3个，消费者有8个。分区数量和消费者数量一致，为什么会出现一个消费者对应多个分区的情况。已验证没消费分区的消费者无问题，因为重启会

回答 节点。csn
采纳率0%
  • 1

    回答

kafka 如何优先级消费 比如 优先级低的100万在队列消费 优先级高的100万过来的时候 就先消费优先级高的

kafka 如何优先级消费 比如 优先级低的100万在队列消费 优先级高的100万过来的时候 就先消费优先级高的

回答 你好～yjl
采纳率0%