package com.atguigu;

import org.apache.pulsar.client.api.PulsarClient;
import org.apache.pulsar.client.api.PulsarClientException;

/**
 * Created by wss on 2019/4/16
 */
public class Client {

    private PulsarClient client;

    public Client() throws PulsarClientException {
        client = PulsarClient.builder();//创建客户端
                .serviceUrl(“pulsar://hadoop101:6650”)
                .build();
    }
    public void Close() throws PulsarClientException {
        client.close();
    }
    public PulsarClient getPulsarClient(){
        return client;
    }
}

Message with content Hello World ,atguigu1 successfully sent

Start pulsartopic is: persistent://public/default/topic2,data is: Hello World ,atguigu1

Message received: Hello World ,atguigu1