From 72290812c33397ffcbd989d3f91480427eb388fe Mon Sep 17 00:00:00 2001 From: Ronak Date: Tue, 28 Jun 2022 13:45:07 +0530 Subject: [PATCH] fix: adds group.id as part of stream config --- .../schemas/backendEntityView-tableConfigFile.json | 1 + pinot-servicemanager/schemas/logEventView-tableConfigFile.json | 1 + pinot-servicemanager/schemas/rawServiceView-tableConfigFile.json | 1 + pinot-servicemanager/schemas/rawTraceView-tableConfigFile.json | 1 + .../schemas/serviceCallView-tableConfigFile.json | 1 + pinot-servicemanager/schemas/spanEventView-tableConfigFile.json | 1 + 6 files changed, 6 insertions(+) diff --git a/pinot-servicemanager/schemas/backendEntityView-tableConfigFile.json b/pinot-servicemanager/schemas/backendEntityView-tableConfigFile.json index 84023f9..4f57934 100644 --- a/pinot-servicemanager/schemas/backendEntityView-tableConfigFile.json +++ b/pinot-servicemanager/schemas/backendEntityView-tableConfigFile.json @@ -16,6 +16,7 @@ }, "tableIndexConfig": { "streamConfigs": { + "group.id": "backendEntityView", "streamType": "kafka", "stream.kafka.consumer.type": "LowLevel", "stream.kafka.decoder.class.name": "org.hypertrace.pinot.plugins.GenericAvroMessageDecoder", diff --git a/pinot-servicemanager/schemas/logEventView-tableConfigFile.json b/pinot-servicemanager/schemas/logEventView-tableConfigFile.json index 126b9fe..41729cc 100644 --- a/pinot-servicemanager/schemas/logEventView-tableConfigFile.json +++ b/pinot-servicemanager/schemas/logEventView-tableConfigFile.json @@ -16,6 +16,7 @@ }, "tableIndexConfig": { "streamConfigs": { + "group.id": "logEventView", "streamType": "kafka", "stream.kafka.consumer.type": "LowLevel", "stream.kafka.decoder.class.name": "org.hypertrace.pinot.plugins.GenericAvroMessageDecoder", diff --git a/pinot-servicemanager/schemas/rawServiceView-tableConfigFile.json b/pinot-servicemanager/schemas/rawServiceView-tableConfigFile.json index 4d5d4ab..4288ef0 100644 --- a/pinot-servicemanager/schemas/rawServiceView-tableConfigFile.json +++ b/pinot-servicemanager/schemas/rawServiceView-tableConfigFile.json @@ -16,6 +16,7 @@ }, "tableIndexConfig": { "streamConfigs": { + "group.id": "rawServiceView", "streamType": "kafka", "stream.kafka.consumer.type": "LowLevel", "stream.kafka.decoder.class.name": "org.hypertrace.pinot.plugins.GenericAvroMessageDecoder", diff --git a/pinot-servicemanager/schemas/rawTraceView-tableConfigFile.json b/pinot-servicemanager/schemas/rawTraceView-tableConfigFile.json index bf111ca..89121e6 100644 --- a/pinot-servicemanager/schemas/rawTraceView-tableConfigFile.json +++ b/pinot-servicemanager/schemas/rawTraceView-tableConfigFile.json @@ -16,6 +16,7 @@ }, "tableIndexConfig": { "streamConfigs": { + "group.id": "rawTraceView", "streamType": "kafka", "stream.kafka.consumer.type": "LowLevel", "stream.kafka.decoder.class.name": "org.hypertrace.pinot.plugins.GenericAvroMessageDecoder", diff --git a/pinot-servicemanager/schemas/serviceCallView-tableConfigFile.json b/pinot-servicemanager/schemas/serviceCallView-tableConfigFile.json index 0a9b9d0..fff1c55 100644 --- a/pinot-servicemanager/schemas/serviceCallView-tableConfigFile.json +++ b/pinot-servicemanager/schemas/serviceCallView-tableConfigFile.json @@ -16,6 +16,7 @@ }, "tableIndexConfig": { "streamConfigs": { + "group.id": "serviceCallView", "streamType": "kafka", "stream.kafka.consumer.type": "LowLevel", "stream.kafka.decoder.class.name": "org.hypertrace.pinot.plugins.GenericAvroMessageDecoder", diff --git a/pinot-servicemanager/schemas/spanEventView-tableConfigFile.json b/pinot-servicemanager/schemas/spanEventView-tableConfigFile.json index e793516..d4b38bb 100644 --- a/pinot-servicemanager/schemas/spanEventView-tableConfigFile.json +++ b/pinot-servicemanager/schemas/spanEventView-tableConfigFile.json @@ -16,6 +16,7 @@ }, "tableIndexConfig": { "streamConfigs": { + "group.id": "spanEventView", "streamType": "kafka", "stream.kafka.consumer.type": "LowLevel", "stream.kafka.decoder.class.name": "org.hypertrace.pinot.plugins.GenericAvroMessageDecoder",