Kafka
kafka是一种高吞吐量的分布式发布订阅消息系统，她有如下特性： 通过O(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能...
加载中
1
回答
spring集成kafka消费端如何去掉打印的日志？
看到有控制台有接收消息的时候大量打印日志，这个在生产环境肯定没法接受的，看到网上说在log4j里配置日志，但是发现org.apache.kafka=OFF...
1
回答
spring集成kafka消费者监听没有触发是怎么回事？
能运行程序，也能连到服务器上，但是消费者监听没有触发，不知道什么原因 我的kafka消费者文件配置，基础连接的配置属性那部分应该没问题，因为是可以连上的 ...
1
回答
kafka开发的spring集成包需要哪些？
项目要用到kafka，之前没用过，要集成到spring里，网上搜了下发现基本提到了这几个包，spring-integration-kafka， sprin...
8
回答
kafka配置了多个消费者，只有一个消费者收到信息
尼玛，困扰我一年的问题今天终于知道答案了 同一个topic的同一个group下consumer进程只能有一个会收到消息， 但是这个进程内开多个线程（数量<=partition数）是可以实现并行接收消息的
3
回答
kafka消费者处理慢的情况下如何提高消息处理速度?不允许增加分区
如题.最近的一个面试题,说是考虑kafka理论特性.具体要求我可能有理解错误.如果各位有研究一眼看出是什么问题,谢谢给个提示. 我搜索了下,提高消费性能的...
3
回答
4
回答
Kafka java.lang.OutOfMemoryError: Direct buffer memory
SpringBoot集成Kafka，发送消息时，总是抛错：java.lang.OutOfMemoryError: Direct buffer memory...
IntelliJ IDEA
Spring Boot
ZooKeeper
3
回答
kafka streams 如何让多个topic里相同的key数据被分配到同一个task
使用kafka stream同时消费topic A, topicB. A和B的分区数是一样的，A和B的每条数据的key也是一致的，A和B的分区策略也是一样...
Spring
Java
2
回答
kafka的消费者stream iterator block，读不出消息？
rt，能够向kafka produce数据，kafka里也看得到，但是consumer却读不出数据，offset是0，程序在stream的iterator...
Apache5
回答
后端开发中间件方向应该怎么规划路线呢？
目前对中间件职位，职业规划这块基本不了解，貌似仅有比较大的公司才有专门做中间件开发/研发的。 市场上大部分的职位与中间件相关的好像有大数据开发工程师、普通...
1
回答
Kafka又遇到问题了。
2018-07-30 08:50:44,193 1814485878 [=slovedShareListener-kafka-consumer-1] IN...
4
回答
kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？
kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？ [2018-08-23 07:56:11,788] INFO [GroupCoordin...
1
回答
kafka客户端连接失败
1、远程服务器安装的zookeeper和kafka，在服务器上启动生产者和消费者之间是正常的可以通信 2、使用java写kafka的客户端，一直连接不上远...
4
回答
Oracle数据库数据变更同步到kafka？
现有Oracle数据库保存订单信息等数据，需要Kafka方式同步到其他系统，有没有好的方法，在尽量不改老系统的前提下，将数据库的变更实时同步到Kafka
1
回答
debezium+kafka connect中消息的before字段怎么去掉？
如何能只显示after，不显示before呢？或者我只显示某个被更新的字段，而不用把所有的字段在更新前后都显示呢？
2
回答
Kafka0.9之后，如何获取到consuemr，topic，以及partition的offset信息
kafka0.9版本之后，consumer的消费信息不再存放在zookeeper端了，我想写java代码调到offset信息，zkClient已经不能用了...
1
回答
windows下kafka1.0源码环境，日志清理报错，直接退出程序
[2018-06-19 15:08:57,934] ERROR Error while loading log dir D:\WORK\002-KAFKA...
1
回答
kafka1.0 offset自动清理后取值-1的问题
offsets.retention.minutes = 一周 log.cleanup.policy = 默认 现象： 一周内，没有任何数据进来，consu...
没有更多内容
加载失败，请刷新页面
本周
本月
