Update KafkaShowcase.java

refactor

Author: adinauer

sentry-samples/sentry-samples-console/src/main/java/io/sentry/samples/console/kafka/KafkaShowcase.java

@@ -28,7 +28,7 @@ private KafkaShowcase() {}
 
   public static void demonstrate(final String bootstrapServers) {
     final CountDownLatch consumedLatch = new CountDownLatch(1);
-    final Thread consumerThread = startKafkaConsumerThread(TOPIC, bootstrapServers, consumedLatch);
+    final Thread consumerThread = startKafkaConsumerThread(bootstrapServers, consumedLatch);
 
     final Properties producerProperties = getProducerProperties(bootstrapServers);
 
@@ -60,7 +60,7 @@ public static void demonstrate(final String bootstrapServers) {
   }
 
   private static Thread startKafkaConsumerThread(
-      final String topic, final String bootstrapServers, final CountDownLatch consumedLatch) {
+      final String bootstrapServers, final CountDownLatch consumedLatch) {
     final Thread consumerThread =
         new Thread(
             () -> {
@@ -90,6 +90,10 @@ private static Thread startKafkaConsumerThread(
   private static Properties getConsumerProperties(String bootstrapServers) {
     final Properties consumerProperties = new Properties();
 
+    consumerProperties.put(
+      ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG,
+      SentryKafkaConsumerInterceptor.class.getName());
+
     consumerProperties.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
     consumerProperties.put(
         ConsumerConfig.GROUP_ID_CONFIG, "sentry-console-sample-" + UUID.randomUUID());
@@ -99,9 +103,6 @@ private static Properties getConsumerProperties(String bootstrapServers) {
     consumerProperties.put(
         ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG,
         StringDeserializer.class.getName());
-    consumerProperties.put(
-        ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG,
-        SentryKafkaConsumerInterceptor.class.getName());
     consumerProperties.put(ConsumerConfig.DEFAULT_API_TIMEOUT_MS_CONFIG, 2000);
     consumerProperties.put(ConsumerConfig.REQUEST_TIMEOUT_MS_CONFIG, 2000);
 
@@ -111,13 +112,14 @@ private static Properties getConsumerProperties(String bootstrapServers) {
   private static Properties getProducerProperties(String bootstrapServers) {
     final Properties producerProperties = new Properties();
 
+    producerProperties.put(
+      ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, SentryKafkaProducerInterceptor.class.getName());
+
     producerProperties.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
     producerProperties.put(
       ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
     producerProperties.put(
       ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
-    producerProperties.put(
-      ProducerConfig.INTERCEPTOR_CLASSES_CONFIG, SentryKafkaProducerInterceptor.class.getName());
     producerProperties.put(ProducerConfig.MAX_BLOCK_MS_CONFIG, 2000);
     producerProperties.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 2000);
     producerProperties.put(ProducerConfig.DELIVERY_TIMEOUT_MS_CONFIG, 3000);