关于 Kafka 的文章

在生活中我们经常会遇到比如在每隔5分钟，统计用户的下单次数，每隔1分钟，统计下股票的涨跌数据等等，这种就是时间窗口相关的应用场景，在实际的工作中我们遇到的比比皆是，因此这篇文章我们主要给大家演示下使用spark st...

这篇文章我们完整的演示一下，利用spark structured streaming编写spark的流处理，从kafka里面消费json，然后把json转换成对象，再利用spark sql进行查询或者join等，计算...

在上一个案例里面我们演示了使用spark structured streaming对接kafka的数据，但是在代码里面编写比较简单，这里我们完整的列举下使用到的kafka信息参数。一、必选参数：序号参数值说明1kaf...

在上一篇文章《CDC工具Canal的安装并且使用JAVA客户端读取数据变更》我们介绍了搭建canal服务端，然后使用java程序监听数据的变化。在使用java客户端监听的时候，在大数据了的场景下这个就不合适了，因为并...

最近需要使用到kafka，一看测试环境竟然没有，那就只能搭建一个，一般我们生产上都是使用tar包进行安装，毕竟像这种搞io类型的应用我们需要是尽量发挥他的性能。但是测试环境就不一样了，没有太高的要求，因此测试环境就使...

这里写一个kafka生产者的代码示例，方便后期拿来即可使用。1、pom.xml中引入kafka的依赖<!-- https://mvnrepository.com/artifact/org.apache...

version: '3'services:  kafka:    container_name: kafka...