[CLI-3513] Temporarily remove Confluent Control Center from confluent local services (#3074)

Author: sgagniere

cmd/docs/main.go

@@ -114,7 +114,7 @@ func createTemporaryConfluentHome() (string, error) {
 		return "", err
 	}
 
-	path := filepath.Join(dir, "share/java/confluent-control-center/control-center-0.0.0.jar")
+	path := filepath.Join(dir, "share/java/confluent-rebalancer/confluent-rebalancer-0.0.0.jar")
 
 	if err := os.MkdirAll(filepath.Dir(path), 0777); err != nil {
 		return "", err

internal/local/command_services.go

@@ -39,7 +39,7 @@ var (
 			isConfluentPlatformOnly: false,
 			envPrefix:               "CONNECT",
 		},
-		"control-center": {
+		/*"control-center": {
 			startDependencies: []string{
 				"zookeeper",
 				"kafka",
@@ -51,13 +51,13 @@ var (
 			port:                    9021,
 			isConfluentPlatformOnly: true,
 			envPrefix:               "CONTROL_CENTER",
-		},
+		},*/
 		"kafka": {
 			startDependencies: []string{
 				"zookeeper",
 			},
 			stopDependencies: []string{
-				"control-center",
+				//"control-center",
 				"ksql-server",
 				"connect",
 				"kafka-rest",
@@ -102,7 +102,7 @@ var (
 		"zookeeper": {
 			startDependencies: []string{},
 			stopDependencies: []string{
-				"control-center",
+				//"control-center",
 				"ksql-server",
 				"connect",
 				"kafka-rest",
@@ -122,7 +122,7 @@ var (
 		"kafka-rest",
 		"connect",
 		"ksql-server",
-		"control-center",
+		//"control-center",
 	}
 )
 

internal/local/command_services_test.go

@@ -28,12 +28,12 @@ func TestGetConnectConfig(t *testing.T) {
 	req.Equal(exampleFile, os.Getenv("CLASSPATH"))
 }
 
-func TestGetControlCenterConfig(t *testing.T) {
+/*func TestGetControlCenterConfig(t *testing.T) {
 	want := map[string]string{
 		"confluent.controlcenter.data.dir": exampleDir,
 	}
 	testGetConfig(t, "control-center", want)
-}
+}*/
 
 func TestGetKafkaConfig(t *testing.T) {
 	want := map[string]string{
@@ -134,7 +134,7 @@ func TestConfluentPlatformAvailableServices(t *testing.T) {
 		"kafka-rest",
 		"connect",
 		"ksql-server",
-		"control-center",
+		//"control-center",
 	}
 	req.Equal(want, got)
 }

pkg/local/confluent_home.go

@@ -140,8 +140,9 @@ func (ch *ConfluentHomeManager) FindFile(pattern string) ([]string, error) {
 }
 
 func (ch *ConfluentHomeManager) IsConfluentPlatform() (bool, error) {
-	controlCenter := "share/java/confluent-control-center/control-center-*.jar"
-	files, err := ch.FindFile(controlCenter)
+	// check for rebalancer because it is enterprise only
+	rebalancer := "share/java/confluent-rebalancer/confluent-rebalancer-*.jar"
+	files, err := ch.FindFile(rebalancer)
 	if err != nil {
 		return false, err
 	}

pkg/local/confluent_home_test.go

@@ -73,7 +73,7 @@ func (s *ConfluentHomeTestSuite) TestHasFile() {
 func (s *ConfluentHomeTestSuite) TestIsConfluentPlatform() {
 	req := require.New(s.T())
 
-	file := "share/java/confluent-control-center/control-center-0.0.0.jar"
+	file := "share/java/confluent-rebalancer/confluent-rebalancer-0.0.0.jar"
 	req.NoError(s.createTestConfluentFile(file))
 
 	isCP, err := s.ch.IsConfluentPlatform()

test/fixtures/output/local/destroy.golden

@@ -2,7 +2,6 @@ The local commands are intended for a single-node development environment only,
 As of Confluent Platform 8.0, Java 8 will no longer be supported.
 
 Using CONFLUENT_CURRENT: .+confluent.\d{6}
-Control Center is \[DOWN\]
 ksqlDB Server is \[DOWN\]
 Connect is \[DOWN\]
 Kafka REST is \[DOWN\]