kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？
kafak主节点cpu 内存持续飙高，不回收，最后服务挂掉问题？ [2018-08-23 07:56:11,788] INFO [GroupCoordinator 0]: Stabilized group consumer.web.l…
kafka开发的spring集成包需要哪些？
项目要用到kafka，之前没用过，要集成到spring里，网上搜了下发现基本提到了这几个包，spring-integration-kafka， spring-kafka， kafka-clients，但…
Kafka又遇到问题了。
2018-07-30 08:50:44,193 1814485878 [=slovedShareListener-kafka-consumer-1] INFO [o.a.k.c.c.i.AbstractCoordinator] - Marking the coordinator …
spring集成kafka消费端如何去掉打印的日志？
看到有控制台有接收消息的时候大量打印日志，这个在生产环境肯定没法接受的，看到网上说在log4j里配置日志，但是发现org.apache.kafka=OFF是可以起作…
kafka启动异常问题
java.lang.NullPointerException at kafka.log.OffsetIndex.kafka$log$OffsetIndex$$forceUnmap(OffsetIndex.scala:310) at kafka.lo…
java的api 消费kafka报错，，java.lang.NoClassDefFoundError: org/apache/kafka/common/security/JaasUtils
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/kafka/common/security/JaasUtils at kafka.consumer.ZookeeperConsume…
kafka streams 如何让多个topic里相同的key数据被分配到同一个task
使用kafka stream同时消费topic A, topicB. A和B的分区数是一样的，A和B的每条数据的key也是一致的，A和B的分区策略也是一样的（使用默认的）。 现在…
kafka消费者处理慢的情况下如何提高消息处理速度?不允许增加分区
如题.最近的一个面试题,说是考虑kafka理论特性.具体要求我可能有理解错误.如果各位有研究一眼看出是什么问题,谢谢给个提示. 我搜索了下,提高消费性能…
Oracle数据库数据变更同步到kafka？
现有Oracle数据库保存订单信息等数据，需要Kafka方式同步到其他系统，有没有好的方法，在尽量不改老系统的前提下，将数据库的变更实时同步到Kafka …
windows下kafka1.0源码环境，日志清理报错，直接退出程序
[2018-06-19 15:08:57,934] ERROR Error while loading log dir D:WORK02-KAFKAkafka-1.0.1-srckafka-logs (kafka.log.LogManager) java.nio.file.Fil…
Kafka0.9之后，如何获取到consuemr，topic，以及partition的offset信息
kafka0.9版本之后，consumer的消费信息不再存放在zookeeper端了，我想写java代码调到offset信息，zkClient已经不能用了，请问还有其他方式吗？…
kafka 如何动态添加consumer
有3个consumer c0，c1,c2都在group-0 下， 当kafka server和各个consumer都在运行的情况下，能否动态添加一个c3在group-0下，我本地测试了一下，看log…
