Skip to content

Commit

Permalink
Corrected typo
Browse files Browse the repository at this point in the history
Hi Stephane think you mistyped, I noticed when doing a compare on my own work whilst doing the course.
  • Loading branch information
Stuzanna authored Dec 26, 2022
1 parent 224674b commit 6fd3a3f
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -20,13 +20,13 @@ public class ConsumerDemoWithShutdown {
public static void main(String[] args) {
log.info("I am a Kafka Consumer");

String boostrapServers = "127.0.0.1:9092";
String bootstrapServers = "127.0.0.1:9092";
String groupId = "my-third-application";
String topic = "demo_java";

// create consumer configs
Properties properties = new Properties();
properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, boostrapServers);
properties.setProperty(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
properties.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
properties.setProperty(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
properties.setProperty(ConsumerConfig.GROUP_ID_CONFIG, groupId);
Expand Down

0 comments on commit 6fd3a3f

Please sign in to comment.