Properties
Properties props? = new Properties()
props.put(xxxx,xxxxx);
props.put(xxxx,xxxxx);
props.put(xxxx,xxxxx);
ProducerRecord <String , xxxClass> record = ProdecerRecord<String ,xxxClass>
(topic de name, key,value :可以是值或者是個封裝好信息的類)
Producer<String ,String :具體這倆string控制什么我也鬧不清楚> producer? = new KafkaProducer<>(props);
好像是指定key和value的序列化方式 這里第二個String 應該改成xxxClass
最后調(diào)用send方法
for（循環(huán)xx次）{
? ? prodecer.send(record);
}
配置
1，bootstrap.servers 必傳 一組指定的host：port
2，key.serializer 字節(jié)數(shù)組 使用卡夫卡默認的序列化的工具org.apache.kafka.common.serialization.StringSerializer
3，value.serializer 同上
io.confluent.kafka.serializers.KafkaAvroSerializer
上邊三個是必傳的
4，PROPERTY_SCHEMA_REGISTRY_URL 連接器 書里沒講
5，ACKS_CONFIG -1 1 all 分別是 不進行重傳 只寫到主服務器? 所有都要重傳?
-1的吞吐量最大 all最小 1是折中
6，RETRIES_CONFIG重試次數(shù)
7，MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION 最大發(fā)送請求的數(shù)量
8，batch.size 一次發(fā)送多少個 大巴車最多乘客40人
9，linger.ms 超過多少秒后必須發(fā)車?
還有什么 壓縮機制 暫時不想寫了
