SchemaRegistry.java

PulsarClient client = PulsarClient.builder()
        .serviceUrl("pulsar://localhost:6650")
        .build();

Producer<SensorReading> producer =      
    client.newProducer(JSONSchema.of(SensorReading.class))
        .topic("sensor-data")
        .create();

Consumer<SensorReading> consumer =    
    client.newConsumer(JSONSchema.of(SensorReading.class)
        .topic("sensor-data")
        .subscriptionName("sensor-subscriber")
        .subscribe();