[CLI-3544] Only set consumer.interceptor.classes and producer.interceptor.classes for Confluent Platform 7.9 or lower (#3086)

sgagniere · web-flow · commit 0f528bb9ac30 · 2025-05-01T14:25:07.000-07:00
diff --git a/internal/local/command_services.go b/internal/local/command_services.go
@@ -467,7 +467,7 @@ func (c *command) getConfig(service string) (map[string]string, error) {
 		config["dataDir"] = data
 	}
 
-	if isCP && slices.Contains([]string{"connect", "kafka-rest", "ksql-server", "schema-registry"}, service) {
+	if isCP && slices.Contains([]string{"connect", "kafka-rest", "ksql-server", "schema-registry"}, service) && zookeeperMode {
 		config["consumer.interceptor.classes"] = "io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor"
 		config["producer.interceptor.classes"] = "io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor"
 	}

Original file line number	Diff line number	Diff line change
`@@ -467,7 +467,7 @@ func (c *command) getConfig(service string) (map[string]string, error) {`
`467`	`467`	`config["dataDir"] = data`
`468`	`468`	`}`
`469`	`469`
`470`		`- if isCP && slices.Contains([]string{"connect", "kafka-rest", "ksql-server", "schema-registry"}, service) {`
	`470`	`+ if isCP && slices.Contains([]string{"connect", "kafka-rest", "ksql-server", "schema-registry"}, service) && zookeeperMode {`
`471`	`471`	`config["consumer.interceptor.classes"] = "io.confluent.monitoring.clients.interceptor.MonitoringConsumerInterceptor"`
`472`	`472`	`config["producer.interceptor.classes"] = "io.confluent.monitoring.clients.interceptor.MonitoringProducerInterceptor"`
`473`	`473`	`}`