整理的springboot整合Pulsar的案例 (TDMQ)
前言:
由于时间比较赶,TDMQ被项目启用了,很多高阶的还没有用上,这里只是简单的发送接收
初始化连接
package com.menglar.soap.item.common.pulsar;
import org.apache.pulsar.client.api.AuthenticationFactory;
import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.shade.io.netty.util.concurrent.DefaultThreadFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import javax.an
共有 0 条评论