程序包 com.cdkjframework.kafka.consumer.service

接口 ConsumerService

public interface ConsumerService

方法概要

修饰符和类型	方法	说明
void	onMessage(String topics, String message)	消息内容

方法详细资料

onMessage

void onMessage(String topics,
 String message)
        throws GlobalException

消息内容

参数:

topics - 主题

message - 内容

抛出:

GlobalException - 异常信息