Skip to content

Commit efd8727

Browse files
committed
fix
1 parent 7661f6c commit efd8727

File tree

1 file changed

+1
-1
lines changed
  • sentry-samples/sentry-samples-console/src/main/java/io/sentry/samples/console/kafka

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ private static Thread startKafkaConsumerThread(
6868

6969
try (KafkaConsumer<String, String> consumer =
7070
new KafkaConsumer<>(consumerProperties)) {
71-
consumer.subscribe(Collections.singletonList(topic));
71+
consumer.subscribe(Collections.singletonList(TOPIC));
7272

7373
while (!Thread.currentThread().isInterrupted() && consumedLatch.getCount() > 0) {
7474
final ConsumerRecords<String, String> records =

0 commit comments

Comments
 (0)