Producer<String, String> producer = new KafkaProducer<>(props); String topic = "my-topic"; String key = "key
根据上边的规则,下图中的映射关系: key-1 -> node-1 key-3 -> node-2 key-4 -> node-2 key-5 -> node-2 key-2 -> node-0 如果想要访问某个
根据上边的规则,下图中的映射关系: key-1 -> node-1 key-3 -> node-2 key-4 -> node-2 key-5 -> node-2 key-2 -> node
如下图所示: 如上图所示,key-1、key-2、key-3可能被映射到同一个节点node0上。导致node0负载过大,而node1和node2却很空闲的情况。
consistentHashing = new ConsistentHashing(nodes); // 模拟数据请求 String[] keys = {"Key-1", "Key-2", "Key