小编Rak*_*odi的帖子

如果我不提任何,kafka如何决定分区

这就是我产生消息的方式:

String json = gson.toJson(msg);

ProducerRecord<String, String> record = new ProducerRecord<>(kafkaProducerConfig.getTopic(), json);
long startTime = System.currentTimeMillis();

try {
    RecordMetadata meta = producer.send(record).get(5, TimeUnit.SECONDS);
} catch (InterruptedException e) {
    e.printStackTrace();
} catch (ExecutionException e) {
    e.printStackTrace();
} catch (TimeoutException e) {
    e.printStackTrace();
}
Run Code Online (Sandbox Code Playgroud)

我有15这个主题的分区,我在制作时没有提到分区键,默认分配的分区是什么?

java apache-kafka kafka-producer-api

6
推荐指数
1
解决办法
2081
查看次数

标签 统计

apache-kafka ×1

java ×1

kafka-producer-api ×1