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

排行榜

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

频道

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

    回答

kafka 消费失败方案

问题遇到的现象和发生背景 kafka的消费失败方案 用代码块功能插入代码，请勿粘贴截图 我的解答思路和尝试过的方法 现有的思路是通过spring提供的消费重试机制和转发死信队列机制来处理；但是没办法

  • kafka
  • 8
  • 2022-09-29 15:37
回答 残·影
  • 2

    回答

Kafka多分区下如何避免数据重复？

单分区情况下可以通过enable.idempotence开启幂等 那多分区的情况下如何避免呢？

回答 qq_41866860
采纳率0%
  • 0

    回答

kafka如何解除消费组和主题之间的关系

elk链路-filebeat→kafka→logstash→eselk中，logstash配置剔除几个的topic后发现kafka消息堆积，检查后发现kafka的消费组内有还有剔除的topic，导致l

回答 qq_15423523
采纳率0%
  • 1

    回答

zookeeper 设置 Acl 后 kafka 启动失败

问题遇到的现象和发生背景 zookeeper设置acl权限之后，kafka启动报错 用代码块功能插入代码，请勿粘贴截图 运行结果及报错内容 我想要达到的结果 希望kafka可以正常启动。可以在ka

回答 weixin_48484941
采纳率50%
  • 0

    回答

kafka增加安全配置报错问题

问题遇到的现象和发生背景 按照教程，给kafka增加安全配置，但是在第8步，启动kafka 的时候会报错误。ClusterAuthorizationException: Request Request

  • kafka
  • 11
  • 2022-09-26 15:55
回答 weixin_48484941
采纳率50%
  • 2

    回答

kafka可以实现跨分区消息幂等吗？

RT假如我有两个Producer实例，分别都开启了事务，且事务id一样但是实例A消息发送到0分区，实例B消息发送到1分区这样可以做到消息的幂等性吗？

回答 qq_41866860
采纳率0%
  • 0

    回答

编译librdkafka出错

问题遇到的现象和发生背景 从https://github.com/edenhill/librdkafka%E4%B8%8B%E8%BD%BD%E7%9A%841.9.2%E7%89%88%E6%9C%

回答 happycool_123
  • 1

    回答

Xshell无法启动kafka

Xshell 无法启动kafka 输入jps不显示用命令bin/kafka-server-start.sh config/server1.properties启动 但不成功

adlicn
采纳率75%
  • 2

为什么kafka启动总是报错呢？

兄弟姐妹们，就是把kafka的安装包解压到了/home/hadoop/目录下，然后就应该算是安装好了(虚拟机里已经安装过hadoop、zookeeper和hive了，而且都能正常使用，jdk虽然是但是

要吃宵夜吗
采纳率100%
  • 1

    回答

sparkstreaming怎么手动提交偏移量

使用pyspark操作sparkstreaming读取kafka数据后，手动管理偏移量，应该如何提交？

回答 code_peasent
采纳率0%
  • 2

    回答

kafka消费组创建不了

ABC三台服务器部署kafkaabc三台服务器部署应用应用启动时会在kafka上创建 消费组 命名方式:ip+应用名开发环境中a,b,c都创建成功 在测试环境中出现了 a,b创建成功,c创建失败并且

新手村@村长
采纳率70%
  • 1

flinkSQL创建kafka源表，解析ogg-json失败

问题遇到的现象和发生背景 ： 软件版本：flink-1.15.1，kafka-2.12-2.81，OGG-19.1.0.0最终目的：创建 flink 的 kafka 源表，解析 ogg-json 数据

奇迹虎虎
采纳率100%
  • 2

    回答

kafka消费者无法收到消息

问题遇到的现象和发生背景 使用docker在一台服务器上安装了kafka集群（3节点） 问题相关代码，请勿粘贴截图 开启生产者与消费者，发现生产者能与入消息，但消费者收不到，另外通过kafka-con

  • ¥10
  • kafka
  • 14
  • 2022-08-24 15:11
熊猫不爱吃鱼
采纳率0%
  • 1

kafka消费者创建不了

一个应用jar包部署三台服务器.kafka也部署三台然后应用A,B,C三台都应该去kafka消费者组里创建一个消费者.但是C却永远不行,怎么重启C都不行.A和B都可以我再换台机器D也部署jar,发现D

新手村@村长
采纳率70%
  • 1

kafka这个日志这个是什么意思？

Kafka这个日志是什么意思呢？连接不到这个端口ip? 还是别的什么错误？

  • kafka
  • 12
  • 2022-08-13 20:54
i进击的攻城狮
采纳率100%
  • 1

请问kafka的配置文件1中这两个参数是做什么的？

listeners和advertised.listeners分别代表什么？我如果要修改Kafka的端口为9093，应该怎么改？

  • kafka
  • 6
  • 2022-08-13 20:32
i进击的攻城狮
采纳率100%
  • 2

    回答

kafka集群报错： Invalid receive (size = 1212501072 larger than 419430400)

问题遇到的现象和发生背景 kafka集群频繁报错 [2022-08-10 17:06:21,806] WARN [SocketServer brokerId=3] Unexpected error f

回答 fabivsMaxims
采纳率50%
  • 1

    回答

Spring-kafka消费暂停不会立即执行

在使用kafka时，遇到了业务需求。需要在消费一条消息后，暂停消费。等回调接口触发时，恢复消费。我使用的是Spring-kafka注解@KafkaListener。在网上搜索一大堆后，得到了一种方式：

繁花与我何干
采纳率0%
  • 5

    回答

Spring-kafka消费暂停不会立即执行

在使用kafka时，遇到了业务需求。需要在消费一条消息后，暂停消费。等回调接口触发时，恢复消费。我使用的是Spring-kafka注解@KafkaListener。在网上搜索一大堆后，得到了一种方式：

繁花与我何干
采纳率0%
  • 1

在虚拟机运行kafka，kafka自动就掉

在虚拟机运行kafka，每隔一会就自动宕机，kafka自动就掉，这个有什么解决办法吗

  • kafka
  • 48
  • 2022-07-26 14:54
花溪★流年
采纳率66.7%
  • 1

K8S kafka集群外部访问的问题

如图，上面是一个kafka的service，配置了一个工作负载，有三个容器，现在外部访问报错，报错如下图 请假如何解决

梦魇中
采纳率90%
  • 1

    回答

flinksql client 连接kafka select * from table没有数据报错，如何解决？

flinksql client 连接kafkaselect * from table没有数据报错：[ERROR] Could not execute SQL statement. Reason:org

回答 guodu1223
采纳率66.7%
  • 2

订单超时如果增加个暂停功能怎么做？

1.订单超时如果增加个暂停功能怎么做？比如订单未支付15分钟取消，现在加个管理员可以暂停这个时间，取消暂停后继续倒计时。 2.在这订单超时的时候需要根据剩余时间提前通知下用户，现在是用的mq做延迟通知

「已注销」
采纳率66.7%
  • 3

    回答

常用的消息中间件有哪些？

在日常的常规的开发中遇到的，常用的消息中间件有哪些？都是如何使用的？适应场景是什么？

回答 Jennifer33K
采纳率25%
  • 3

flinksql读取kafka数据报错

flinksql读取kafka数据报错flinksql创建kafka的表成功了，但是在查询的时候报错报错信息如下： 网络是通的，kafka版本：kafka_2.12-3.1.0flink版本：flin

guodu1223
采纳率66.7%
  • 1

spring+kafka+hive实现动作提取到数据仓库

spring+kafka+hive实现动作提取到数据仓库， spring在动作之前设置埋点，通过kafka发送到HIVE，请问大家，有没有实现过，或者有没有一些思路

梦魇中
采纳率90%
  • 1

    回答

kafka的isDone()方法的返回值解释让人疑惑

如题，我在测试时代码如下，但消费者成功消费到生产者的消息了缺仍然走返回为“false”，看了原代码注释之后有些疑惑 while (true) { String

  • kafka
  • 28
  • 2022-07-04 10:13
回答 冰a冰
采纳率83.3%
  • 5

    回答

prometheus监控kafka的问题

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

kc32668287
采纳率29.6%
  • 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

克伦留索夫
采纳率80%