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