Skip to content

Instantly share code, notes, and snippets.

@pavangadagi

pavangadagi/kafkaConfig.java

Last active March 25, 2020 06:56
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 pavangadagi/4eee9d43b48dcd73c216500371fdc3d0 to your computer and use it in GitHub Desktop.
Save pavangadagi/4eee9d43b48dcd73c216500371fdc3d0 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
kafkaConfig.java
Map<String,Object> kafkaParams = new HashMap<String, Object>();
kafkaParams.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, brokers);
kafkaParams.put(ConsumerConfig.GROUP_ID_CONFIG, groupId);
kafkaParams.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
kafkaParams.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, JsonDeserializer.class);
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment