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

排行榜

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

频道

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

    回答

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

  • kafka
  • 8
  • 2022-09-29 15:37
  • 2

    回答

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

  • 0

    回答

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

  • 1

    回答

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

  • 0

    回答

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

  • kafka
  • 11
  • 2022-09-26 15:55
  • 2

    回答

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

  • 0

    回答

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

  • 1

    回答

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

adlicn
采纳率75%
  • 2

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

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

    回答

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

  • 2

    回答

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

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

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

奇迹虎虎
采纳率100%
  • 2

    回答

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

  • ¥10
  • kafka
  • 14
  • 2022-08-24 15:11
  • 1

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

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

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

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

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

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

    回答

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

  • 1

    回答

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

  • 5

    回答

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

  • 1

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

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

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

梦魇中
采纳率90%
  • 1

    回答

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

回答 guodu1223
采纳率66.7%
  • 2

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

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

    回答

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

  • 3

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

guodu1223
采纳率66.7%
  • 1

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

梦魇中
采纳率90%
  • 1

    回答

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

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

    回答

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

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

克伦留索夫
采纳率80%