zk中有两种角色:Leader 和 Fllower
Leader是自己的集群各台电脑投票选举出来的。
事务:一通操作,要么同时成立,要么都不成立。
举例:Jack 和 Rose Rose 给 Jack(小李子) 转钱
Rose -100
J…
1. 自定义拦截器
interceptor是拦截器,可以拦截到发送到kafka中的数据进行二次处理,它是producer组成部分的第一个组件。
public static class MyInterceptor implements ProducerInterceptor<String,String>{Overridepublic ProducerRecord<…