diff --git a/config/samples/banzaicloud_v1beta1_kafkacluster.yaml b/config/samples/banzaicloud_v1beta1_kafkacluster.yaml index efaecc9bb..bec24fa61 100644 --- a/config/samples/banzaicloud_v1beta1_kafkacluster.yaml +++ b/config/samples/banzaicloud_v1beta1_kafkacluster.yaml @@ -270,6 +270,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/kafkacluster-with-istio.yaml b/config/samples/kafkacluster-with-istio.yaml index d6b5502d7..c9a5bd26d 100644 --- a/config/samples/kafkacluster-with-istio.yaml +++ b/config/samples/kafkacluster-with-istio.yaml @@ -97,6 +97,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/kafkacluster_with_external_ssl.yaml b/config/samples/kafkacluster_with_external_ssl.yaml index c317a78e5..1013e20f2 100644 --- a/config/samples/kafkacluster_with_external_ssl.yaml +++ b/config/samples/kafkacluster_with_external_ssl.yaml @@ -108,6 +108,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/kafkacluster_with_internal_ssl_vault.yaml b/config/samples/kafkacluster_with_internal_ssl_vault.yaml index aa99f9f34..2391d313a 100644 --- a/config/samples/kafkacluster_with_internal_ssl_vault.yaml +++ b/config/samples/kafkacluster_with_internal_ssl_vault.yaml @@ -93,6 +93,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/kafkacluster_with_ssl_groups.yaml b/config/samples/kafkacluster_with_ssl_groups.yaml index 785c0356b..8bcf41116 100644 --- a/config/samples/kafkacluster_with_ssl_groups.yaml +++ b/config/samples/kafkacluster_with_ssl_groups.yaml @@ -96,6 +96,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/kafkacluster_without_ssl.yaml b/config/samples/kafkacluster_without_ssl.yaml index 05b3647b5..793086e49 100644 --- a/config/samples/kafkacluster_without_ssl.yaml +++ b/config/samples/kafkacluster_without_ssl.yaml @@ -104,6 +104,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/kafkacluster_without_ssl_groups.yaml b/config/samples/kafkacluster_without_ssl_groups.yaml index 8061c44e1..73a0e7a37 100644 --- a/config/samples/kafkacluster_without_ssl_groups.yaml +++ b/config/samples/kafkacluster_without_ssl_groups.yaml @@ -90,6 +90,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/simplekafkacluster.yaml b/config/samples/simplekafkacluster.yaml index b8b690a01..d40811f74 100644 --- a/config/samples/simplekafkacluster.yaml +++ b/config/samples/simplekafkacluster.yaml @@ -91,6 +91,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/config/samples/simplekafkacluster_ebs_csi.yaml b/config/samples/simplekafkacluster_ebs_csi.yaml index 277adf707..bd1ed9518 100644 --- a/config/samples/simplekafkacluster_ebs_csi.yaml +++ b/config/samples/simplekafkacluster_ebs_csi.yaml @@ -97,6 +97,7 @@ spec: metric.sampler.partition.assignor.class=com.linkedin.kafka.cruisecontrol.monitor.sampling.DefaultMetricSamplerPartitionAssignor # The metric sampling interval in milliseconds metric.sampling.interval.ms=120000 + metric.anomaly.detection.interval.ms=180000 # The partition metrics window size in milliseconds partition.metrics.window.ms=300000 # The number of partition metric windows to keep in memory diff --git a/pkg/sdk/v1beta1/kafkacluster_types.go b/pkg/sdk/v1beta1/kafkacluster_types.go index 5fb216bad..9a83558ff 100644 --- a/pkg/sdk/v1beta1/kafkacluster_types.go +++ b/pkg/sdk/v1beta1/kafkacluster_types.go @@ -543,7 +543,7 @@ func (cConfig *CruiseControlConfig) GetCCImage() string { if cConfig.Image != "" { return cConfig.Image } - return "solsson/kafka-cruise-control@sha256:658c21295a940b4c490aadfb95973b34f27fd9c944c3f11a2a9b89e5948a78bd" + return "banzaicloud/cruise-control:2.4.2" } // GetImage returns the used image for Prometheus JMX exporter