Consumer<GenericRecord> pulsarConsumer = client.newConsumer(Schema.AUTO_CONSUME())
…
.subscribe();
Message<GenericRecord> msg = consumer.receive() ;
GenericRecord record = msg.getValue();
Created
July 9, 2019 07:38
-
-
Save sijie/1b30bbc3a1cc167fb70e453a7c554e27 to your computer and use it in GitHub Desktop.
AutoConsume Example
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment