-
6.重要的生产者参数
重要的生产者参数 1. acks 2. max.request.size 3. retries和retry.backoff.ms 4. compression.type 5. connections.max.idle.ms 6. linger.ms 7. receive.buffer.bytes 8. send.buffer.bytes 9.... -
86.如何保证mysql和redis的实时性一致性
如何保证mysql和redis的实时性一致性 如何保证mysql和redis的实时性一致性 保证MySQL和Redis的实时一致性可以通过以下方法： 写入MySQL后更新Redis：在数据写入MySQL后，同步更新Redis。 使用MySQL的二进制日志（binlog）和消息队列：监控MySQL的binlog变更，然后通过消息队列将变更同步到Re... -
83.Redis 有哪些数据结构？
83.Redis 有哪些数据结构？ 83.Redis 有哪些数据结构？ 如果你是 Redis 普通玩家，可能你的回答是如下五种数据结构： 字符串 String 字典Hash 列表List 集合Set 有序集合 SortedSet 如果你是 Redis 中级玩家，还需要加上下面几种数据结构： HyperLogLog Geo Bitmap 如... -
80.消费端弄丢了数据？
80.消费端弄丢了数据？ 80.消费端弄丢了数据？ 唯一可能导致消费者弄丢数据的情况，就是说，你消费到了这个消息，然后消费者那边自动提交了 offset ，让 Broker 以为你已经消费好了这个消息，但其实你才刚准备处理这个消息，你还没处理，你自己就挂了，此时这条消息就丢咯。 这不是跟 RabbitMQ 差不多吗，大家都知道 Kafka 会自动提... -
1. 什么是消息队列？
1. 什么是消息队列？ 1. 什么是消息队列？ 消息队列，是分布式系统中重要的组件。 主要解决应用耦合，异步消息，流量削锋等问题。 可实现高性能，高可用，可伸缩和最终一致性架构，是大型分布式系统不可缺少的中间件。 目前主流的消息队列有 Kafka RabbitMQ RocketMQ ，老版本是 MetaQ 。 ActiveMQ ，目前用的人... -
9. 反序列化
反序列化 反序列化 在第4节中我们讲述了 KafkaProducer 对应的序列化器，那么与此对应的 KafkaConsumer 就会有反序列化器。Kafka 所提供的反序列化器有 ByteBufferDeserializer、ByteArrayDeserializer、BytesDeserializer、DoubleDeserializer、Flo... -
7.消费者与消费组
消费者与消费组 消费者与消费组 与生产者对应的是消费者，应用程序可以通过 KafkaConsumer 来订阅主题，并从订阅的主题中拉取消息。不过在使用 KafkaConsumer 消费消息之前需要先了解消费者和消费组的概念，否则无法理解如何使用 KafkaConsumer。本章首先讲解消费者与消费组之间的关系，进而再细致地讲解如何使用 KafkaCo... -
四、使用场景
计数器 缓存 查找表 消息队列 会话缓存 分布式锁实现 其它 计数器 可以对 String 进行自增自减运算，从而实现计数器功能。 Redis 这种内存型数据库的读写性能非常高，很适合存储频繁读写的计数量。 缓存 将热点数据放到内存中，设置内存的最大使用量以及淘汰策略来保证缓存的命中率。 查找表 例如 DNS 记录就很适合使... -
73.为什么不能以 Partition 作为存储单位？
73.为什么不能以 Partition 作为存储单位？ 73.为什么不能以 Partition 作为存储单位？ 如果就以 Partition 为最小存储单位，可以想象，当 Kafka Producer 不断发送消息，必然会引起 Partition 文件的无限扩张，将对消息文件的维护以及已消费的消息的清理带来严重的影响，因此，需以 segment 为单... -
71.Redis 有什么优点？
71.Redis 有什么优点？ 71.Redis 有什么优点？ ? 1. 速度快 因为数据存在内存中，类似于 HashMap ，HashMap 的优势就是查找和操作的时间复杂度都是O (1) 。 Redis 本质上是一个 Key-Value 类型的内存数据库，很像 Memcached ，整个数据库统统加载在内存当中进行操作，定期通过异步操作把...