1、创建topic bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 2、查看创建的topic bin/kafka-topics.sh --list --zookeeper localh…
二、kafka常用的shell命令
三、python操作kafka
一、基本概念回顾 Topic：一组消息数据的标记符； Producer：生产者，用于生产数据，可将生产后的消息送入指定的Topic； Consumer：消费者，获取数据，可消费指定的Topic； Group：消费者组，同一个group可以有多个消费者，一条消息在一个group中，只会被一个消费者获取； Partition：分区，为了保证kafka的…
redis与mysql双写一致性
一、一致性介绍 要实现redis与mysql的双写一致性，那先来搞清楚什么是一致性、为何用要做到一致性、一致性的实现种类 [collapse title="详解"] 1、什么是一致性C（Consistency）？ 一致性就是数据保持一致，在分布式系统中，可以理解为多个节点中数据的值是一致的。 2、为何要做到数据一致？ 以微博为例，分布式系统的服务器…