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

    回答

如何提高kafka写入clickhouse速度

如何提高kafka写入clickhouse速度使用c写入kafka主题时经常报local：queue full

回答 qq_40629656
采纳率33.3%
  • 1

    回答

kafka consumer producer broker参数怎样设置才能确保消息不丢失不重复

测试环境为单台公网服务器上行下行带宽有限的情况下。如果同时有大量的consumer消费消息或者producer生产消息的话。势必会网络拥堵，网络不稳定。 请问在网络环境不稳定（比如突然有大量客户端数据

回答 weixin_47921890
采纳率0%
  • 1

    回答

kafka-manager cmak网页页面显示不正常

图片样式都显示不了看了下源码文件路径发现在cmak的路径里发现没有发现相关的文件和路径，看网上的帖子没有一个人反应这个问题，好奇怪。

  • kafka
  • 2
  • 2024-09-09 16:16
weixin_47921890
采纳率0%
  • 1

    回答

kafka consumer消费者offset会出现重复怎么回事儿

跑的librdkafka里的consumer.c例子。编译成win32控制台程序运行。 broker上有120条消息，consumer消费者把这120条消息全部poll下来，但是发现poll过程中，o

weixin_47921890
采纳率0%
  • 1

    回答

topic扩分区后，新分区的部分消息被跳过了

您好，我们使用了的是2.4.2版本的kafka，auto.offset.reset=latest，topic扩分区后，新扩的分区的部分消息，被消费者跳过了，这种我们想通过调整metadata.max.

  • kafka
  • 1
  • 2024-09-07 17:10
回答 沐榕樰
采纳率0%
  • 1

    回答

librdkafka consumer poll拉取数据第一次很慢

跑的librdkafka-2.1.0自带的consumer.c程序编译的windows平台下win32控制台程序。发现rkm = rd_kafka_consumer_poll(rk, 100); 函

weixin_47921890
采纳率0%
  • 1

    回答

springboot 配置kafka消费

一个kafka topic 有16个分区,单机启动一个springboot 服务消费，通过concurrency配置了4个线程进行消费，每个线程被分配了4个分区。问题：工作一段时间后，其中一个消费线程

回答 zhaohuijiadelu
采纳率0%
  • 2

    回答

jar包启动kafka的问题

环境: windows server 2012kafka版本: kafka_2.13-3.2.1SpringBoot+kafka: jar包启动报错:一直打印Join group failed wit

  • kafka
  • 6
  • 2024-08-23 15:23
回答 吃货智
采纳率0%
  • 24

    回答

zk+kafka三节点，zk异常重新选主后导致的高可用问题

三节点kafka和zk，当所有服务都正常运行时，手动kill掉zk的leader进程触发zk重新选主后，此时创建kafka的Topic时，该Topic的分区leader 以及isr 均为空，只有重启k

m0_64269309
采纳率0%
  • 1

    回答

Kafka：CorruptRecordException

Kafka：CorruptRecordException: record size is smaller than mininum record overhead异常，kafka启动失败，无法正常启动

  • kafka
  • 3
  • 2024-08-07 20:17
回答 三少和左眼皮
采纳率0%
  • 2

    回答

seatunnel消费kafka（json字符串），json体里空值的字段缺失，导致解析后字段值错位，这种情况如何解决？

seatunnel消费kafka（json字符串），json体里空值的字段缺失，导致解析后字段值错位，这种情况如何解决？ env { execution.mode = "cluster" p

回答 wutian713
采纳率25%
  • 3

    回答

python这边生产出kafka信息，kafka那边咋消费不到

我这个代码感觉没问题，为啥我生产处来后，然后kafka那边消费不到 from kafka import KafkaProducer import json # 创建Kafka生产者 pr

回答 wendy_stt
采纳率66.7%
  • 36

    回答

人工分析一个亿级消息接收处理策略的问题？

问题简述：一个应用系统A 需要通过HTTP接口接收某外部系统B的消息，系统A 提供3个接口，接收来自系统B的三类消息，每月数据总量约150亿条，经处理后推送前端。请问如何设计（请根据问题细节叠加人工分

pursuergreece
采纳率0%
  • 4

    回答

kafka-rest-proxy 启动报错

使用confluent的kafka-rest-proxy 启动kafka-rest，为什么会提示找不到主类io.confluent.kafkarest.KafkaRestMain

回答 weixin_53002845
采纳率0%
  • 3

    回答

kafka-rest-proxy启动报错

配置好了confluent的kafka-rest-proxy cmd启动报下错，环境变量也是好的，怎么回事？

  • kafka
  • 2
  • 2024-07-02 14:01
回答 weixin_53002845
采纳率0%
  • 2

    回答

Flink端到端的精确一次实验报错

操作步骤我这边的操作：生产者消费者没接收到;运行KafkaEOSDemo.java程序出现报错

回答 苏默曦
采纳率50%
  • 3

kafka创建topic时报错Failed to create new KafkaAdminClient

kafka和zook已启动 创建topic（主题） ，主题名称为test1[hadoop@node2 kafka_2.12-3.3.1]$ kafka-topics.sh --bootstrap-s

苏默曦
采纳率50%
  • 2

    回答

Pycharm中运行kafka的相关代码报错

kafka运行代码有问题但是我已经下载了kafka-python的相关包了 D:\Pycharm\pythonProject\.venv\Scripts\python.exe D:\Pycharm\p

回答 、念安я
采纳率0%
  • 3

kafka消费者组异常

程序启动时通过 consumer = kafkaSecondFactory.createConsumer(“testTopic”,null); consumer.subscribe(Collect

  • kafka
  • 5
  • 2024-05-29 11:13
kraida
采纳率57.1%
  • 1

    回答

Kfaka为什么不显示那个蓝色的圆圈

这个是我的.java文件 下面是应该呈现的.java文件的模样 我是那里出错了

  • kafka
  • 5
  • 2024-05-28 19:24
553scc v
采纳率68%
  • 21

    回答

kafka客户端跨网段访问，看日志提示连接的还剩内网地址，且访问不通

内部地址：192.168.0.11-13映射地址：10.16.0.10listeners=INSIDE://192.168.0.11:9092,OUTSIDE://0.0.0.0:9093advert

xhredeem
采纳率11.8%
  • 3

    回答

深入解析：如何基于GB32960标准，使用Java构建车联网数据接入网关

深入解析：如何基于GB32960标准，使用Java构建车联网数据接入网关 dispatcher项目启动后 kafka连接不上 控制台2024-05-13 12:00:26.418 [main] INF

回答 Ehivk
采纳率0%
  • 4

    回答

flume数据无法发送

请问FlumeRpcClientExample运行时遇到这种问题该怎么解决？ rg.apache.flume.EventDeliveryException: NettyAvroRpcClient {

回答 废柴太乙
采纳率0%
  • 3

kafka服务启动有问题

kafka问题我的kafka是在win10上搭建的,zk启动成功，然后kafka好像有点问题，哪位可以帮我提点建议

  • kafka
  • 0
  • 2024-05-08 13:22
MM2133
采纳率77.8%
  • 4

    回答

kafka故障恢复后，一些副本不会自动同步，求指导

kafka故障恢复后，副本不会自动同步kafka遇到IO负载高的情况，修复了负载问题之后，大部分副本已经同步，但有小部分副本一直不回自动同步，一天了，怎么处理？求指导。 [ec@htkf-1-1 ~]

回答 略小赞
采纳率0%
  • 5

    回答

这个要导入什么依赖包嘛还是啥子问题啊？

idea运行报错，kafka服务已经正常启动了，不知道是要导包还是什么问题？

  • kafka
  • 12
  • 2024-04-29 11:28
回答 邦邦达亚
采纳率66.7%
  • 19

    回答

kafka 分区副本增加会导致消息丢失或者不可用吗？

kafka 分区副本增加会导致消息丢失或者不可用吗？ 增加所有topic分区的副本数会对现在的集群有什么影响？

xhredeem
采纳率11.8%
  • 5

    回答

关于#kafka#的问题，请各位专家解答！(语言-java)

偶现问题 com.sf.kafka.api.client.KafkaConsumer24$ConsumeTask|run|319|consume error,calcCount=1,topic: DA

回答 苏苏要变更好
采纳率25%
  • 3

    回答

如何用比例-积分（PI）控制器给(399.94 s)/(0.0000000007 s^2 + 0.000014*s + 1)传递函数设计闭环传递函数

如何用比例-积分（PI）控制器给(399.94 s)/(0.0000000007 s^2 + 0.000014*s + 1)传递函数设计闭环传递函数

回答 sjsjxhd
采纳率5.9%
  • 4

elk+kafka+filebeat，增加第二个filebeat收集日志时报错

elk+kafka+filebeatfilebeat 只收集一台服务器kafka服务器的日志时没出现问题 kafka-topics.sh --bootstrap-server kafka:9092 -

zero_open
采纳率63.6%