Kafka
kafka是一种高吞吐量的分布式发布订阅消息系统，她有如下特性： 通过O(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能...
加载中
3
回答
win10下如何使用docker安装ZooKeeper、Flink、Kafka?
win10下如何使用docker安装ZooKeeper、Flink、Kafka? 各位前辈能给出一些win10安装ZooKeeper、Flink、Kafk...
Docker
ZooKeeper
Apache Flink
5
回答
kafka(版本 0.10)已消费过的数据重复消费，而且是3天前的，zk的log未发现异常
kafka(版本 0.10)已消费过的数据重复消费，而且是3天前的，zk的log未发现异常 三台机器分布式消费，下面是消费端配置 props.put("a...
1
回答
在原kafka集群动态增加分区后，发现刚增加的分区和原分区数据量差距太大？
现在遇到了一个kafka集群分区扩容问题，详细情况为： 我现在kafka 集群为5台机器，现在的主题中分区数为8个，但是没有添加新的机器，只是想将现在的分...
1
回答
Kafka 即时推送
项目需要向多个租户下推送消息，但是总不能每个租户都创建一个topic吧？如果都同时丢在同一个topic里面，那么消息量少的租户可能被消息量大的租户阻塞，比...
Java1
回答
spring boot整合kafka中自定义分区怎么加入到配置中?
我发现KafkaTemplate 和 KafkaProperties 都没有关于设置Partitioner的地方? 也搜不到; 难道只能用Properti...
Spring Boot3
回答
1
回答
2
回答
请问Kafka怎么实现延时消息
请问Kafka怎么实现延时消息，用于做定时器，网上一堆写的都是时间轮什么的，有没有大神给个实例，或者给一个实现思路也行
Spring1
回答
kafka-producer-network-thread | producer-1] WARN NetworkClien这咋整
2019-10-12 17:47:37.535 [kafka-producer-network-thread | producer-1] WARN Net...
1
回答
kafka-manager 异常问题
请求页面显示：Yikes! Ask timed out on [ActorSelection[Anchor(akka://kafka-manager-sy...
1
回答
1
回答
6
回答
kafka集群启动后，每隔10分钟就跳出一条日志，很影响操作
kafka集群启动后，每隔10分钟就跳出一条日志，很影响操作，求教如何关闭日志打印 [2019-03-19 12:56:48,635] INFO [Gro...
1
回答
关于kafka占用centos7 存储空间
不一定是容器占满的，是你的根分区满了。你先看下是不是/var/log下面的日志比较占用空间。如果容器占用空间是/var/lib/docker下数据比较大。
8
回答
kafka连接zookeeper超时。zookeeper是自己搭建的！！但是无限报超时的错误。
下面是主节点和从节点的zookeeper状态： 但是 kafka报错： 这是什么情况， brokerid 和myid 两个都没有错。防火墙也关了 ，服务器...
7
回答
1
回答
kafka_2.11-1.0.0在控制台kafka-console-consumer消费者消费的时候zookeeper 和 bootstrap-server区别
今天试了两个kafka的版本都存在这个问题 1、创建一个topic kafka-topics.bat --create --partitions 1 --...
5
回答
kafka集群出现奇怪的现象
各位好： 最近在研究kafka的时候遇到一个奇怪的现象，还请不灵赐教！ 1：当集群环境运行一段时间后会出现奇怪错误，zookeeper无法连接到其中一个n...
1
回答
希望有大佬帮我讲解下kafka里的分区，备份，消费者读取数据，希望通俗点谢谢
比如kafka配置的是两个分区，三个备份，一个主题，broker个数为三，那么我以下说的对吗？三个备份的话，每个broker下都有一个主题，同时主题里都有...
4
回答
Kafka 与 k8s/docker， 应用是共享还是独占？？
想问下大家部署的kafka集群是共享集群，还是独占集群。 是一个应用，部署一套Kafka集群+k8s。 还是共享一个Kafka集群，上面通过不同的topi...
没有更多内容
加载失败，请刷新页面
本周
本月
