老师为何结果我这个不对啊

来源:5-3 Producer异步阻塞发送演示

qq_慕莱坞4316410

2020-09-25

key-i:0 partition:0 offset:50
key-i:1 partition:0 offset:51
key-i:2 partition:0 offset:52
key-i:3 partition:0 offset:53
key-i:4 partition:0 offset:54
key-i:5 partition:0 offset:55
key-i:6 partition:0 offset:56
key-i:7 partition:0 offset:57
key-i:8 partition:0 offset:58
key-i:9 partition:0 offset:59

代码
public static void ProducerSyncSend() throws Exception{
Properties properties=new Properties();
properties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG,“192.168.59.129:9092”);
properties.put(ProducerConfig.ACKS_CONFIG,“all”);
properties.put(ProducerConfig.RETRIES_CONFIG,“0”);
properties.put(ProducerConfig.BATCH_SIZE_CONFIG,“16384”);
properties.put(ProducerConfig.LINGER_MS_CONFIG,“1”);
properties.put(ProducerConfig.BUFFER_MEMORY_CONFIG,“33554432”);

    properties.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");
    properties.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG,"org.apache.kafka.common.serialization.StringSerializer");

    Producer<String,String>producer=new KafkaProducer<>(properties);

    for (int i=0;i<10;i++) {
        String key="key-i:"+i;
        ProducerRecord<String, String> producerRecord = new ProducerRecord<>(topicName,"key-:"+key
                +"value-:"+i);
        Future<RecordMetadata>send=producer.send(producerRecord);
        RecordMetadata metadata=send.get();
        System.out.println(key+"\t partition:"+metadata.partition()+"\t offset:"+metadata.offset());
    }
    producer.close();
}

是哪里写错了啊

写回答

1回答

Allen

2020-09-25

正确的结果应该是什么

1
2
Allen
回复
qq_慕莱坞4316410
抱歉,因为你是在看视频,所以知道效果, 但是我直接回忆具体效果是什么有点难, 能描述清楚一些么
2020-09-27
共2条回复

Kafka多维度系统精讲,从入门到实战开发

系统讲解Kafka,实战结合,让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程