目錄結構
pom依賴
org.springframework.boot
spring-boot-starter-parent
2.0.1.release
org.springframework.kafka
spring-kafka
org.springframework.boot
spring-boot-starter-web
# kafka
spring:
kafka:
# kafka伺服器位址(可以多個)
bootstrap-servers: 192.168.144.169:9092,192.168.144.170:9092,192.168.144.171:9092
consumer:
# 指定乙個預設的組名
group-id: kafka2
# earliest:當各分割槽下有已提交的offset時，從提交的offset開始消費；無提交的offset時，從頭開始消費
# latest:當各分割槽下有已提交的offset時，從提交的offset開始消費；無提交的offset時，消費新產生的該分割槽下的資料
# none:topic各分割槽都存在已提交的offset時，從offset後開始消費；只要有乙個分割槽不存在已提交的offset，則丟擲異常
auto-offset-reset: earliest
# key/value的反序列化
key-deserializer: org.apache.kafka.common.serialization.stringdeserializer
value-deserializer: org.apache.kafka.common.serialization.stringdeserializer
producer:
# key/value的序列化
key-serializer: org.apache.kafka.common.serialization.stringserializer
value-serializer: org.apache.kafka.common.serialization.stringserializer
# 批量抓取
batch-size: 65536
# 快取容量
buffer-memory: 524288
# 伺服器位址
bootstrap-servers: 192.168.144.169:9092,192.168.144.170:9092,192.168.144.171:9092
package com.mayikt;
import org.apache.kafka.clients.consumer.consumerrecord;
import org.springframework.beans.factory.annotation.autowired;
import org.springframework.kafka.annotation.kafkalistener;
import org.springframework.kafka.core.kafkatemplate;
import org.springframework.web.bind.annotation.restcontroller;
/** *
* @author 餘勝軍
*/@restcontroller
public class kafkacontroller
// test 主題 1 my_test 3
public string testkafka()
return "success";
} public static void main(string args)
/*** 消費者使用日誌列印訊息
*/@kafkalistener(topics = "test")
public void receive(consumerrecord, ?> consumer)
}
啟動專案
瀏覽器輸入**
後台得到的訊息
然後將topic:zhangsan
輸入上面同樣的**
得到訊息
SpringBoot如何整合druid
springboot相比mvc來說，在配置上極大的節省了開發者的時間與精力，這無疑對開發者是一種不可抗拒的 今天筆者就springboot如何整合druid跟大夥作個分享 druid的pom依賴 com.alibaba druid spring boot starter 1.1.4 datasour...
SpringBoot中如何整合Servlet呢？
下文筆者將講述兩種springboot整合servlet的方法，如下所示 實現思路 方式1 使用全註解的方式開發 1.1 在啟動類上面加上註解 servletcomponentscan 1.2 編寫servlet程式，並在servlet程式上加上註解 webservlet name testserv...
SpringBoot如何整合nacos詳解
nacos支援基於dns和基於rpc的服務發現，可以作為springcloud的註冊中心 動態配置服務 動態dns服務。nacos註冊中心分為server和client，server採用j a編寫，為client提供註冊發現與配置服務。中介軟體 因為推薦使用的是2.0.1版本，我這裡 2.0.1版本...