柚子快報激活碼778899分享：分布式 Kafka學習

http://yzkb.51969.com/

結構

分為消費者 Croducer 主題 Topic 生產(chǎn)者 Producer 其中Topic包括 Topic中包括了分區(qū)和offset偏移量的概念；

一個簡單的Kafka發(fā)消息收消息java代碼： 消費者：

@Component

public class EventConsumer {

@Resource

private KafkaTemplate kafkaTemplate;

// 采用監(jiān)聽得方式接收

@KafkaListener(topics = {"test"},groupId = "hello")

public void onEvent(String event){

System.out.println("讀取到了時間消息: " + event);

}

}

生產(chǎn)者

@Component

public class EventProducer {

@Resource

private KafkaTemplate kafkaTemplate;

// 消息發(fā)送

public void sendEvent(String message){

kafkaTemplate.send("test",message);

}

}

消費者偏移量的設置

發(fā)送消息的一些方法

// 消息發(fā)送

public void sendEvent(String message){

kafkaTemplate.send("test",message);

}

// 發(fā)送message對象

public void sendEvent2(String message){

// 創(chuàng)建message對象

Message kafka = MessageBuilder.withPayload(message)

// 設置topic

.setHeader(KafkaHeaders.TOPIC,"test")

.build();

kafkaTemplate.send(kafka);

}

public void sendEvent3(String message){

// 消費者可以從Headers中取到信息.

Headers headers = new RecordHeaders();

headers.add("orderId","123".getBytes(StandardCharsets.UTF_8));

ProducerRecord record = new ProducerRecord<>(

"test",

0,

System.currentTimeMillis(),

"k1",

message,

headers);

kafkaTemplate.send(record);

}

柚子快報激活碼778899分享：分布式 Kafka學習

http://yzkb.51969.com/

好文閱讀