赞
踩
#!/bin/bash
#1.创建一个名为demo的Topic
kafka-topics.sh -create --zookeeper 127.0.0.1:2181 --replication-factor 1 --partitions 3 --topic demo
#2.查看所有Topic
kafka-topics.sh --list --zookeeper 127.0.0.1:2181
#3.查看名为demo的Topic的详情信息
kafka-topics.sh -topic demo --describe --zookeeper 127.0.0.1:2181
package net.educoder; import org.apache.kafka.clients.producer.KafkaProducer; import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.ProducerRecord; import java.util.Properties; /** * kafka producer 简单模式 */ public class App { public static void main(String[] args) { /** * 1.创建配置文件对象,一般采用 Properties */ /**----------------begin-----------------------*/ Properties props = new Properties(); /**-----------------end-------------------------*/ /** * 2.设置kafka的一些参数 * bootstrap.servers --> kafka的连接地址 127.0.0.1:9092 * key、value的序列化类 -->org.apache.kafka.common.serialization.StringSerializer * acks:1,-1,0 */ /**-----------------begin-----------------------*/ props.put("bootstrap.servers", "127.0.0.1:9092"); props.put("acks", "1"); props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); props.put("value.serializer",
赞
踩
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。