上一篇博客我们讲过如果一个类实现了ImportSelector接口，并且在配置类中被@Import加入到Spring容器中以后。Spring容器就会把ImportSelector接口方法返回的字符串数组中的类new出来对象然后放到工厂中去。并且做了一个功能开关的例子辅助讲解其功能。这次我们就接着上次讲解ImportSelector接口的内容继续扩展讲解ImportBeanDefinitionReg

前言最近有一个需求，要调用外部API满足业务逻辑，然后就用到了重试机制，又联想到不止API，其实很多中间件，比如Reids、各类MQ、Kafka，这些涉及到连接失败的读取写入需求都应该有重试机制。虽然最终需求使用了Spring自带的Retry机制，但是这一套还是太重了，思考了下就写了一个简易Retry功能分享出来。主要是利用Java的lambda表达式和线程接口实现有返回值和无返回值的重试。代码p

由于Apache官方一直没有提供AdminClient中对账户这一块的操作，因此这部分大多数时候都是用命令行去操作的，但是命令行毕竟不是很方便。为了解决这部分问题，笔者去读了Kafka Scala的源码，从中梳理出来这部分内容供给大家参考。

很久没有更新Kafka API相关的文档了，因为笔者工作变动Kafka这部分内容在工作中接触的就相对于之前少了一些。但架不住kafka官方还是一如既往的勤奋，官方操作Scram账户的创建与删除这部分已经更新了好久了，这次也算是填坑吧，主要就是针对alterUserScramCredentials方法做一个功能说明和demo。给网上少之又少的Kafka API中文使用教程做个增补，本次基于Kafka

前言本篇文章主要讲解Kafka的集群搭建以及一些注意事项。之所以写这篇博客，是因为网上充斥着单机集群搭建的教程。但是服务器集群和单机虽说是理论上是通的，但是不一样的地方还是很多，尤其是Zookeeper操作就明显不一样。至少得先把Zookeeper搭建起来成功运行才能继续Kafka集群的搭建。而且在配置上服务器集群和单机集群确实有很多注意不到的点。这篇文章就是要把服务器集群整个流程写下来，供给后来

前言好久没有更新AdminClient的博客，主要是一直在摸索怎么用的，官网写的太简略，只能一边研究官网，一边研究源码注释。而且KafkaAPI更新速度飞一样，版本兼容也是个问题，刚刚知道怎么用的，版本过时了又得看新的。而且有些功能API没有提供，就只能去钻研Scala源码，好在和Java差不了很多，虽然不会写，但是勉勉强强能读懂，对于笔者正在开发的项目来说真是崩溃了。所以等笔者把这些内容整理整理

Apache Kafka API AdminClient 账号权限赋予与移除

AdminClient上一篇【Apache Kafka API AdminClient 获取对象】我们说了怎么获取一个AdminClient，那么这篇博客我们就说下怎么用AdminClient去创建和删除topic的。这个功能可以说是非常有用的，当你的需求越来越多的时候，可能会面临一次创建数十个或者数百个topic的状况。这个时候一个一个的用命令行敲进去显然是要敲死人的，真的是会敲死人的，问我为什

前言最近工作上需要使用Java开发一个操作Kafka的Portal，因为使用命令行去操作比较反人类，尤其是需要进行大量的增删操作的时候。所以研究了一下Apache提供的官方JAVA API应用到了Portal上。在实施的过程中，发现这部分网上可用资料也比较稀少，即便找到几篇也十分的不详细，或者版本比较老旧，或者还在用Zookeeper提供的那一套API，更有甚者干脆互相抄，所以就决定写一个系列希望

Apache提供的AdminClient中针对Topic的操作除了增删以外，自然还会有查询功能。本篇的主要内容是获取Topic列表，获取单个topic的详细信息等等。