com.itstyle.seckill.queue.kafka

Class KafkaConsumer

java.lang.Object

com.itstyle.seckill.queue.kafka.KafkaConsumer

@Component
public class KafkaConsumer
extends Object

消费者 spring-kafka 2.0 + 依赖JDK8

Author:

科帮网 By https://blog.52itstyle.com

Constructor Summary

Constructors

Constructor and Description
KafkaConsumer()

Method Summary

Modifier and Type	Method and Description
void	receiveMessage(String message) 监听seckill主题,有消息就读取

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaConsumer

public KafkaConsumer()

Method Detail

receiveMessage

@KafkaListener(topics="seckill")
public void receiveMessage(String message)

监听seckill主题,有消息就读取

Parameters:

message -