使用分区键来避免回程问题,示例代码如下:
// 设置分区键,确保topic和分区相对应 producer.setkey(serializer.serialize(record.getKey()));
// 发送消息 producer.send(new ProducerRecord<>(topic, partition, serializer.serialize(record)));
上一篇:避免警告:期望的类型是“const struct aiocb * const*”,但实际参数类型为“struct aiocb **”。
下一篇:避免静态视图引用,但允许不同的活动修改视图。