kafka - disable keeping metadata for all topics

Signed-off-by: Fabian Martinez <46371672+famarting@users.noreply.github.com>
dapr · Nov 23, 2023 · 06b5f16 · 06b5f16
1 parent ba5831b
commit 06b5f16
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/common/component/kafka/kafka.go b/common/component/kafka/kafka.go
@@ -78,6 +78,8 @@ func (k *Kafka) Init(_ context.Context, metadata map[string]string) error {
 	config := sarama.NewConfig()
 	config.Version = meta.internalVersion
 	config.Consumer.Offsets.Initial = k.initialOffset
+	// configure the client to not keep the metadata for all the topics in the cluster, just the topics used by this client
+	config.Metadata.Full = false
 
 	if meta.ClientID != "" {
 		config.ClientID = meta.ClientID