Pulsar Producers example

Import java.util.concurrent.TimeUnit;import org.apache.pulsar.client.api.Producer;import org.apache.pulsar.client.api.PulsarClient;import org.apache.pulsar.client.impl.schema.JSONSchema;public class SendMsgTest {public static void main (String [] args) {String url = "http://192.168.1.48:8080"; Try {/ / the first step is to establish a connection PulsarClient client = PulsarClient.builder () .serviceUrl (url) .connectionTimeout (10Med TimeUnit.SECONDS) .build () / / the second step is to create a producer object / / specify the format of sending data (see Pulsar schemas for details) Producer producer=client.newProducer (JSONSchema.of (UserModel.class)) .topic ("my-tenant/my-namespace/testschema-topic") .sendTimeout (10 TimeUnit.SECONDS) .producerName ("senduser") .create () UserModel userModel=new UserModel (); userModel.setName ("testmsg"); userModel.setAge (21); producer.send (userModel); / / synchronous send producer.sendAsync (userModel) asynchronously send System.out.print ("send ok"); client.close ();} catch (Exception e) {e.printStackTrace () }}}

Public class UserModel {

Private String name;private int age;public String getName () {return name;} public void setName (String name) {this.name = name;} public int getAge () {return age;} public void setAge (int age) {this.age = age;}

}