阅读背景:

kafka-consumer1 consumer的一些配置以及同步消费

来源:互联网 

1 实现在同一个线程消费的consumer

  实现producer

package wyp;

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.slf4j.LoggerFactory;

import java.util.Properties;
import java.util.stream.IntStream;

pack



你的当前访问异常,请进行认证后继续阅读剩余内容。

分享到: