ConditionalOnExpression是springboot引入的注解，该注解可以理解为ConditionalOnProperty的更底层的实现，也更灵活，先来看下面的一个应用场景：

环境：scala:2.12spark:3.1.2本文介绍spark从kafka获取数据，并进行反序列化import com.fasterxml.jackson.databind.ObjectMapperimport org.apache.spark.sql.{Row, SparkSession}import...

kafka-eagle是一款不错的kafka监控平台，笔者觉得比kafka-manager可用性要好些，官网地址为www.kafka-eagle.org，下面给出几个使用页面：

kafka是使用十分广泛的一款消息中间件，凭借其强大的吞吐以及可靠性获得了不错的口碑，其在大数据传输方面也有应用，wurstmeister/kafka是目前使用最多的一个kafka docker镜像。kafka的副本数在kafka的高可用性上有着至关...

新版本的kafka会把每个主题消费进度保存在kafka所在机器的__consumer_offsets主题下面，该主题默认副本数为1，当一台机器down掉后，该机器保存的主题消费进度就会丢失，为了保证kafka的高可用，我们必须保证__consumer_offsets...

1、下载zookeeper以及kafka的可执行文件，解压到一个目录，比如/usr/local/bin

比如kafka、mqtt、rabbitmq、send email等，所以我们只需要添加kafka的rule node到规则链即可

书接上文，在分析 Toast 源码的过程中我们涉及到了 Handler，这个在 Android 开发里经常用到的类——线程切换、顺序执行、延时执行等等逻辑里往往少不了它的身影，跟它一起搭配使用的通常是 Runnable 和 Message，还有它身后...

源码在https://reviews.apache.org/r/50692/diff/1#2下面的操作需要cd到

现阶段的Kafka Controller本质上就是Kafka集群中的一台Broker，通过ZK选举出来，负责根据ZK中的元数据维护所有Broker、Partition和Replica的状态。但是，一旦没有了ZK的辅助，Controller就要接手ZK的元数据存储，并且单点Contr...