幂等性是分布式环境下常见的问题;幂等性指的是多次操作,结果是一致的。(多次操作数据库数据是一致的。)
对于Kafka中的分区而言,它的每条消息都有唯一的offset,用来表示消息在分区中对应的位置。对于消费者而言,它也有一个offset的概念,消费者使用offset来表示消费到分区中某个消息所在的位置。在Kafka中其实有关于offset有两...
回顾一下kafka相关的概念:
Kafka是一个消息队列,把消息放到队列里边的叫生产者,从队列里边消费的叫消费者。
Rebalance 本质上是一种协议,规定了一个 Consumer Group 下的所有 consumer 如何达成一致,来分配订阅 Topic 的每个分区。
生产者又名Producer,生产者生成的数据由topic进行标识管理,topic的数据可以通过设置分区写入数据到不同的分区中去。
大致数据流程是kafka的生产者Producer生成数据,通过broker服务写到Topic A中的Partition 0分区中,这个时候数据已经存到磁盘中了,然后Consumer A通过消费把Topic A中的Partition 0中的数据消费出来,存到相关存储DB中。...
2:启动服务运行kafka需要使用zookeeper,所以你需要先启动zookeeper,如果你没有zookeeper,你可以使用kafka自带打包和配置好的zookeeper。启动命令如下:
核心类就是 ThreadLocal ,它提供线程局部变量,每个线程都有自己独立的一份变量,通常是类中的 private static 字段,它们希望将状态与某一个线程相关联,在多线程编程中常用,比如 Android 的绘制同步机制 Choreographer 中也...
这个方法在日常开发中是经常用到的,例如在子线程中我们需要更新 UI,可以通过 post 一个 runnable ,在 run 方法中去绘制 UI ,或者我们需要在 Activity 的 onCreate 中获取一个 View 的宽高时,也会通过 post 一个 runnable ...