update

kishansairam9 · kishansairam9 · commit 0d5b2b0d1f26 · 2024-04-24T15:42:13.000+05:30
diff --git a/kafka-event-listener/src/main/java/org/hypertrace/core/kafka/event/listener/KafkaLiveEventListener.java b/kafka-event-listener/src/main/java/org/hypertrace/core/kafka/event/listener/KafkaLiveEventListener.java
@@ -101,7 +101,7 @@ class ListenerThreadFactory implements ThreadFactory {
   private final String name;
 
   public ListenerThreadFactory(String consumerName) {
-    this.name = "kafka-live-event-listener-" + consumerName;
+    this.name = "kafka-live-event-listener-" + consumerName + "-" + System.currentTimeMillis();
   }
 
   public Thread newThread(Runnable r) {

Original file line number	Diff line number	Diff line change
`@@ -101,7 +101,7 @@ class ListenerThreadFactory implements ThreadFactory {`
`101`	`101`	`private final String name;`
`102`	`102`
`103`	`103`	`public ListenerThreadFactory(String consumerName) {`
`104`		`- this.name = "kafka-live-event-listener-" + consumerName;`
	`104`	`+ this.name = "kafka-live-event-listener-" + consumerName + "-" + System.currentTimeMillis();`
`105`	`105`	`}`
`106`	`106`
`107`	`107`	`public Thread newThread(Runnable r) {`