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

排行榜

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

频道

  • 编程语言
  • 后端
  • Python
  • Java
  • 前端

活动

  • C站认证
  • 大咖来了
  • 悦读时间
最新最热精华悬赏待回答 筛选
  • 0

    回答

  • 7

    浏览

请问这种情况显示的流量 是不是只是1个broker的呀?那应该如何配置呢?

回答 cft0808
采纳率33.3%
2021-09-25 16:20
  • 0

    回答

  • 9

    浏览

我们可以使用 bin/kafka-topics.sh 命令对 Kafka 增加 Kafka 的分区数据,但是 Kafka 不支持减少分区数。 Kafka 分区数据不支持减少是由很多原因的,比如减少的分

回答 咔啡
采纳率89.5%
2021-09-25 10:47
  • 1

  • 8

    浏览

zookeeper 是一个分布式的协调组件,早期版本的kafka用zk做meta信息存储,consumer的消费状态,group的管理以及 offset的值。考虑到zk本身的一些因素以及整个架构较大概

回答 咔啡
采纳率89.5%
2021-09-24 21:33
  • 1

    回答

  • 11

    浏览

创建了两个Kafka topic ,从终端中使用命令可以看见两个,但是在hdfs web端只能看见一个,这是什么原因?

回答 青白渡
采纳率0%
2021-09-23 12:48
  • 1

    回答

  • 7

    浏览

broker 是消息的代理,Producers往Brokers里面的指定Topic中写消息,Consumers从Brokers里面拉取指定Topic的消息,然后进行业务处理,broker在中间起到一

回答 咔啡
采纳率89.5%
2021-09-22 19:23
  • 3

    回答

  • 23

    浏览

如何将json数据写入到Kafka 存入kafka后 如何读取kafka的数据 将数据存入postgresql 中

回答 NoBug、
采纳率0%
2021-09-22 10:43
  • 1

    回答

  • 12

    浏览

我通过kafka命令查询消费组brokers下有哪些消费者时,是没有的 然后,我通过命令行启动一个消费组 再次查询,消费组下有一个消费者 但是,有个前提,就是我flink一直连接了kafka的,并

我想E得足够快
采纳率0%
2021-09-16 15:31
  • 1

    回答

  • 13

    浏览

GitHub下载了librdkafka 1.8.0代码,使用example程序的producer.c文件进行测试,dr_msg_cb回调函数内标识会自动清空rkmessage,但是测试发现并没有自动清

qq_42776318
采纳率0%
2021-09-15 09:45
  • 1

    回答

  • 17

    浏览

请求解释一下原理?无论是linux还是windows都不允许对一个文件同时进行读写操作的吧,kafka底层将接收的消息追加到文件末尾,而发送消息则从文件开头进行读取,请问如何做到的同时读写?

回答 常识与偏见
采纳率50%
2021-09-14 18:45
  • 3

  • 58

    浏览

最近打算做一个消息推送系统,数据量还挺大的,一个月有大概300万,我应该要怎么设计这个系统?又有什么地方需要注意的呢?业务基本上是通过手机号给用户发送通知。还有,像这种系统,一般选用哪种MQ比较好?希

欧吉吉
采纳率50%
2021-09-14 10:43
  • 1

    回答

  • 13

    浏览

用的cdc数据同步工具,现在报了一个错,阅读文件时文件阅读器发生问题,错误代码-1273

  • 0

    回答

  • 4

    浏览

我在kafka建立一个topic,然后诉求如下: 1.客户通过账户登录到系统。 2.kafka在同一个topic下,将属于这个账号的信息推送给这个账户。   比如后端可以通过SQL的where条

  • 1

    回答

  • 24

    浏览

现在是服务器调用我的接口,然后我手动打开kafka监听,返回数据给接口,但是考虑到服务器 的性能,一次只希望消费比如10条左右,但是我设置了max-poll-records这个参数以后,还是会监听到所

回答 m0_37818588
采纳率0%
2021-09-02 10:41
  • 1

    回答

  • 11

    浏览

我的一个开发任务是用nmap扫描出kafka下边的topic信息,但是网上都找不到相关资料,有谁懂得吗

灰色海洋
采纳率0%
2021-08-31 11:50
  • 1

    回答

  • 31

    浏览

org.springframework.kafka.listener.ListenerExecutionFailedException: Listener method 'public void co