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

排行榜

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

频道

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

    回答

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

回答 kc32668287
采纳率33.3%
  • 1

    回答

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

  • kafka
  • 11
  • 2022-06-17 08:02
  • 1

    回答

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

  • 1

    回答

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

  • kafka
  • 7
  • 2022-06-07 23:13
  • 1

    回答

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

回答 LinZP101
采纳率66.7%
  • 1

    回答

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

  • 2

    回答

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

  • 2

    回答

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

  • 1

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

tutou99precent
采纳率100%
  • 2

    回答

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

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

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

zqy518518
采纳率62.5%
  • 1

    回答

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

  • 2

    回答

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

  • 1

    回答

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

  • 1

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

上酱潘凤
采纳率50%
  • 1

    回答

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

  • 2

    回答

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

大_G
采纳率50%
  • 4

    回答

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

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

    回答

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

回答 qq_38431690
采纳率81.8%
  • 1

    回答

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

回答 Zwen14
采纳率0%
  • 8

    回答

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

SYD19970128
采纳率0%
  • 1

    回答

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

  • kafka
  • 43
  • 2022-03-20 14:23
  • 2

    回答

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

  • 2

    回答

一:背景手动poll kafka消息,并且手动提交; 运行的时候,偶尔(频次比较低)会出现如下错误:org.apache.kafka.clients.consumer.RetriableCommitF

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

    回答

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

m0_37994675
采纳率25%
  • 1

    回答

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

  • 1

    回答

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

  • 1

    回答

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

  • 1

    回答

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

  • 1

    回答

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