We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent de04781 commit cd1c003Copy full SHA for cd1c003
1 file changed
src/main/java/org/opentesting/services/adapter/kafka/OpenTestingKafkaConsumer.java
@@ -44,7 +44,8 @@ public class OpenTestingKafkaConsumer {
44
@LogExecutionTime
45
public void createConsumer(TestCaseServiceDTO service, Adapter adapter) {
46
47
- String key = service.getConnectstring()+"#"+service.getCustom("topic").getValue()+"#"+service.getUsername();
+ //shared between test cases
48
+ String key = service.getConnectstring()+"#"+service.getCustom("topic").getValue()+"#"+service.getUsername()+"#"+service.getCustom("group.id").getValue();
49
if (createdConsumers.containsKey(key)) {
50
log.info("kafka consumer already exists: "+key);
51
return;
0 commit comments