Skip to content

Instantly share code, notes, and snippets.

@sijie

sijie/auto-consume-example.md

Created July 9, 2019 07:38
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save sijie/1b30bbc3a1cc167fb70e453a7c554e27 to your computer and use it in GitHub Desktop.
Save sijie/1b30bbc3a1cc167fb70e453a7c554e27 to your computer and use it in GitHub Desktop.
Download ZIP
AutoConsume Example
Raw
auto-consume-example.md 
Consumer<GenericRecord> pulsarConsumer = client.newConsumer(Schema.AUTO_CONSUME())
    …
    .subscribe();
Message<GenericRecord> msg = consumer.receive() ;
GenericRecord record = msg.getValue();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment