码迷,mamicode.com
首页 >  
搜索关键字:flume kafka topic覆盖    ( 5097个结果
动态配置实现原理解析参考资料
Release Notes - Kafka - Version 0.8.1:https://archive.apache.org/dist/kafka/0.8.1/RELEASE_NOTES.htmlRelease Notes - Kafka - Version 0.10.1.0:https://a ...
分类:其他好文   时间:2019-12-17 22:33:25    阅读次数:101
kafka 零拷贝
kafka通过零拷贝实现高效的数据传输 https://blog.csdn.net/lxlmycsdnfree/article/details/78973864 Kafka零拷贝 https://blog.csdn.net/ljheee/article/details/99652448 Kafka高 ...
分类:其他好文   时间:2019-12-17 14:49:07    阅读次数:116
abp 中log4net 集成Kafka
1.安装包 Install-Package log4net.Kafka.Core 2.修改log4net.config 配置文件 参考资料:https://github.com/beckjin/log4net.Kafka.Core ...
分类:Web程序   时间:2019-12-17 13:12:13    阅读次数:130
flink整合kafka报错 WARN - Bootstrap broker ip:9092 disconnected
WARN - The configuration 'zookeeper.connect' was supplied but isn't a known config.WARN - The configuration 'input.topic' was supplied but isn't a kno ...
分类:其他好文   时间:2019-12-17 11:52:26    阅读次数:2471
使用Kafka建立可靠的高性能分布式消息传递基础结构
在优锐课学习中了解到,我们可以看到实施资源适配器以将Kafka与企业Java解决方案集成。码了很多专业的相关知识, 分享给大家参考学习。 由于世界已经变得移动化,因此应用程序现在必须实时提供数据。 不仅重要的是存储在数据库表中的最终结果,而且重要的是用户在使用应用程序时执行的所有操作。 无论可用的任 ...
分类:其他好文   时间:2019-12-17 10:44:54    阅读次数:106
elasticsearch集群搭建 kafka filebeat logstach收集日志高可用方案
文档在很久之前写的了,这里留个记录,我的码云地址 点击查看 ...
分类:其他好文   时间:2019-12-17 00:31:58    阅读次数:95
[转]kafka要等一段时间才能消费到数据
kafka要等一段时间才能消费到数据 pythonkafka 为什么用python写的kafka客户端脚本,程序一运行就能生产数据,而要等一段时间才能消费到数据(topic里面有数据)。(pykafka和confluentKafka都一样) 只有极少的概率立刻可以消费到数据,大多数都要等个几分钟,很 ...
分类:其他好文   时间:2019-12-16 22:14:04    阅读次数:131
kafka没配置好,导致服务器重启之后,topic丢失,topic里面的消息也丢失
转,原文:https://blog.csdn.net/zfszhangyuan/article/details/53389916 这个问题,在线上集群环境一般不容易出现,因为相关的日志文件参数都已经配置好了,而且经受住时间的的验证了。 作为新手,我在本地配置了一个单机kafka,用得是kafka自带 ...
分类:其他好文   时间:2019-12-16 22:05:35    阅读次数:166
流式计算(二)-Kafka Stream
前面说了Java8的流,这里还说流处理,既然是流,比如水流车流,肯定得有流的源头,源可以有多种,可以自建,也可以从应用端获取,今天就拿非常经典的Kafka做源头来说事,比如要来一套应用日志实时分析框架,或者是高并发实时流处理框架,正是Kafka的拿手好戏。 环境:Idea2019.03/Gradle ...
分类:其他好文   时间:2019-12-16 19:31:26    阅读次数:178
Flink生产数据到Kafka频繁出现事务失效导致任务重启
在生产中需要将一些数据发到kafka,而且需要做到EXACTLY_ONCE,kafka使用的版本为1.1.0,flink的版本为1.8.0,但是会很经常因为提交事务引起错误,甚至导致任务重启。 这些错误基本涉及到两阶段提交、事务、checkpoint。 查看kafka documentation和... ...
分类:其他好文   时间:2019-12-16 13:10:45    阅读次数:522
5097条   上一页 1 ... 90 91 92 93 94 ... 510 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!