Kafka整合SpringBoot-蒲公英云

Kafka整合SpringBoot

<!--Spring  整合kafka-->
    <dependency>
      <groupId>org.springframework.kafka</groupId>
      <artifactId>spring-kafka</artifactId>
      <version>1.1.1.RELEASE</version>
    </dependency>

生产者：

@Component
public class KakfaProducer2 {

@Autowired  
private KafkaTemplate<String,String> kafkaTemplate;  
private Gson gson=new Gson();  
//发送消息的方法  
public void send()\{  
    Message message=new Message();  
    message.setId(System.currentTimeMillis());  
    message.setMsg(UUID.randomUUID().toString());  
    message.setSendTime(new Date());  
    kafkaTemplate.send("topic",gson.toJson(message));  
    System.out.println("发送消息："+gson.toJson(message));  
\}

}

application.properties:

#Kafka的配置

#============== kafka ===================
# 指定kafka 代理地址，可以多个
spring.kafka.bootstrap-servers=127.0.0.1:9092

#=============== provider =======================

spring.kafka.producer.retries=0
# 每次批量发送消息的数量
#spring.kafka.producer.batch-size=16384
#spring.kafka.producer.buffer-memory=33554432

# 指定消息key和消息体的编解码方式
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer

#=============== consumer =======================
# 指定默认消费者group id
spring.kafka.consumer.group-id=test-consumer-group

spring.kafka.consumer.auto-offset-reset=earliest
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-commit-interval=100

# 指定消息key和消息体的编解码方式
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

pom.xml文件：

org.springframework.boot
spring-boot-starter-parent
1.5.6.RELEASE

org.springframework.boot
spring-boot-starter-web

org.springframework.boot
spring-boot-starter-test

junit
junit
3.8.1
test

org.springframework.boot
spring-boot-starter-data-mongodb

com.alibaba
fastjson
1.2.7

org.json
json
20131018

com.github.iweinzierl
jsonformat
1.0

com.squareup.okhttp
okhttp
2.3.0

commons-codec
commons-codec
1.9

org.apache.kafka
kafka_2.10
0.10.0.0

org.springframework.kafka
spring-kafka
1.1.1.RELEASE

com.google.code.gson
gson
2.8.2

com.netflix.hystrix
hystrix-core
1.5.12

org.slf4j
1.7.25
slf4j-log4j12

org.projectlombok
lombok
1.16.0
provided

commons-logging
commons-logging
1.2

org.apache.httpcomponents
httpclient
4.5.2

org.springframework.cloud
spring-cloud-starter-config

org.springframework.cloud
spring-cloud-starter-eureka

org.springframework.cloud
spring-cloud-starter-ribbon

org.springframework.cloud
spring-cloud-starter-hystrix

org.springframework.cloud
spring-cloud-dependencies
Dalston.SR1
pom
import

SpringBoot_ES_2