Apache Kafka

Apache Kafka

文章 164 浏览 71

kafak主节点cpu 内存持续飙高,不回收,最后服务挂掉问题?

kafak主节点cpu 内存持续飙高,不回收,最后服务挂掉问题? [2018-08-23 07:56:11,788] INFO [GroupCoordinator 0]: Stabilized group consumer.web.l…

瑾夏年华 2021-12-08 15:23:29 709 0

kafka开发的spring集成包需要哪些?

项目要用到kafka,之前没用过,要集成到spring里,网上搜了下发现基本提到了这几个包,spring-integration-kafka, spring-kafka, kafka-clients,但…

坏尐絯 2021-12-08 03:11:15 757 0

Kafka又遇到问题了。

2018-07-30 08:50:44,193 1814485878 [=slovedShareListener-kafka-consumer-1] INFO [o.a.k.c.c.i.AbstractCoordinator] - Marking the coordinator …

吃颗糖壮壮胆 2021-12-07 18:22:20 798 0

spring集成kafka消费端如何去掉打印的日志?

看到有控制台有接收消息的时候大量打印日志,这个在生产环境肯定没法接受的,看到网上说在log4j里配置日志,但是发现org.apache.kafka=OFF是可以起作…

草莓味的萝莉 2021-12-07 11:42:20 836 0

debezium+kafka connect中消息的before字段怎么去掉?

如何能只显示after,不显示before呢?或者我只显示某个被更新的字段,而不用把所有的字段在更新前后都显示呢?…

奢华的一滴泪 2021-12-07 07:50:00 838 0

kafka启动异常问题

java.lang.NullPointerException &nbsp &nbsp &nbsp &nbsp at kafka.log.OffsetIndex.kafka$log$OffsetIndex$$forceUnmap(OffsetIndex.scala:310) &nb…

哑剧 2021-12-07 01:48:13 896 0

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 &nbsp&nbsp &nbspat kafka.consumer.Zook…

顾挽 2021-12-06 18:39:20 911 0

kafka在docker外如何连接

kafka被配置在docker内,在docker外面要如何使用,有人知道吗,还是说只能建一个dockerswam才行…

够钟 2021-12-06 16:59:58 816 0

kafka streams 如何让多个topic里相同的key数据被分配到同一个task

使用kafka stream同时消费topic A, topicB. A和B的分区数是一样的,A和B的每条数据的key也是一致的,A和B的分区策略也是一样的(使用默认的)。 现在…

输什么也不输骨气 2021-12-06 07:59:18 893 0

kafka消费者处理慢的情况下如何提高消息处理速度?不允许增加分区

如题.最近的一个面试题,说是考虑kafka理论特性.具体要求我可能有理解错误.如果各位有研究一眼看出是什么问题,谢谢给个提示. 我搜索了下,提高消费性能…

青萝楚歌 2021-12-05 22:02:32 752 0

Oracle数据库数据变更同步到kafka?

现有Oracle数据库保存订单信息等数据,需要Kafka方式同步到其他系统,有没有好的方法,在尽量不改老系统的前提下,将数据库的变更实时同步到Kafka &n…

坐在坟头思考人生 2021-12-05 18:22:18 773 0

kafka如何不持久化到磁盘

kafka默认持久化到topic的分区里,但是我想不让他持久化,能做到吗?我找了好久没找到相关的配置,求大神们帮助。…

落墨 2021-12-05 16:26:09 659 0

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…

伪装你 2021-12-05 04:10:57 731 0

Kafka0.9之后,如何获取到consuemr,topic,以及partition的offset信息

kafka0.9版本之后,consumer的消费信息不再存放在zookeeper端了,我想写java代码调到offset信息,zkClient已经不能用了,请问还有其他方式吗?…

终止放荡 2021-12-05 03:26:15 907 0

kafka 如何动态添加consumer

有3个consumer c0,c1,c2都在group-0 下, 当kafka server和各个consumer都在运行的情况下,能否动态添加一个c3在group-0下,我本地测试了一下,看log…

北笙凉宸 2021-12-05 02:03:45 753 0
更多

推荐作者

不再见

文章 0 评论 0

真是无聊啊

文章 0 评论 0

樱娆

文章 0 评论 0

浅语花开

文章 0 评论 0

烛光

文章 0 评论 0

绻影浮沉

文章 0 评论 0

    我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
    原文