@@ -133,12 +133,44 @@ pub mod versioned {
133
133
134
134
/// Kafka settings that affect all roles and role groups.
135
135
/// The settings in the `clusterConfig` are cluster wide settings that do not need to be configurable at role or role group level.
136
- pub cluster_config : KafkaClusterConfig ,
136
+ pub cluster_config : v1alpha1 :: KafkaClusterConfig ,
137
137
138
138
// no doc - docs in ClusterOperation struct.
139
139
#[ serde( default ) ]
140
140
pub cluster_operation : ClusterOperation ,
141
141
}
142
+
143
+ #[ derive( Clone , Deserialize , Debug , Eq , JsonSchema , PartialEq , Serialize ) ]
144
+ #[ serde( rename_all = "camelCase" ) ]
145
+ pub struct KafkaClusterConfig {
146
+ /// Authentication class settings for Kafka like mTLS authentication.
147
+ #[ serde( default ) ]
148
+ pub authentication : Vec < KafkaAuthentication > ,
149
+
150
+ /// Authorization settings for Kafka like OPA.
151
+ #[ serde( default ) ]
152
+ pub authorization : KafkaAuthorization ,
153
+
154
+ /// TLS encryption settings for Kafka (server, internal).
155
+ #[ serde(
156
+ default = "tls::default_kafka_tls" ,
157
+ skip_serializing_if = "Option::is_none"
158
+ ) ]
159
+ pub tls : Option < KafkaTls > ,
160
+
161
+ /// Name of the Vector aggregator [discovery ConfigMap](DOCS_BASE_URL_PLACEHOLDER/concepts/service_discovery).
162
+ /// It must contain the key `ADDRESS` with the address of the Vector aggregator.
163
+ /// Follow the [logging tutorial](DOCS_BASE_URL_PLACEHOLDER/tutorials/logging-vector-aggregator)
164
+ /// to learn how to configure log aggregation with Vector.
165
+ #[ serde( skip_serializing_if = "Option::is_none" ) ]
166
+ pub vector_aggregator_config_map_name : Option < String > ,
167
+
168
+ /// Kafka requires a ZooKeeper cluster connection to run.
169
+ /// Provide the name of the ZooKeeper [discovery ConfigMap](DOCS_BASE_URL_PLACEHOLDER/concepts/service_discovery)
170
+ /// here. When using the [Stackable operator for Apache ZooKeeper](DOCS_BASE_URL_PLACEHOLDER/zookeeper/)
171
+ /// to deploy a ZooKeeper cluster, this will simply be the name of your ZookeeperCluster resource.
172
+ pub zookeeper_config_map_name : String ,
173
+ }
142
174
}
143
175
144
176
impl HasStatusCondition for v1alpha1:: KafkaCluster {
@@ -257,38 +289,6 @@ impl v1alpha1::KafkaCluster {
257
289
}
258
290
}
259
291
260
- #[ derive( Clone , Deserialize , Debug , Eq , JsonSchema , PartialEq , Serialize ) ]
261
- #[ serde( rename_all = "camelCase" ) ]
262
- pub struct KafkaClusterConfig {
263
- /// Authentication class settings for Kafka like mTLS authentication.
264
- #[ serde( default ) ]
265
- pub authentication : Vec < KafkaAuthentication > ,
266
-
267
- /// Authorization settings for Kafka like OPA.
268
- #[ serde( default ) ]
269
- pub authorization : KafkaAuthorization ,
270
-
271
- /// TLS encryption settings for Kafka (server, internal).
272
- #[ serde(
273
- default = "tls::default_kafka_tls" ,
274
- skip_serializing_if = "Option::is_none"
275
- ) ]
276
- pub tls : Option < KafkaTls > ,
277
-
278
- /// Name of the Vector aggregator [discovery ConfigMap](DOCS_BASE_URL_PLACEHOLDER/concepts/service_discovery).
279
- /// It must contain the key `ADDRESS` with the address of the Vector aggregator.
280
- /// Follow the [logging tutorial](DOCS_BASE_URL_PLACEHOLDER/tutorials/logging-vector-aggregator)
281
- /// to learn how to configure log aggregation with Vector.
282
- #[ serde( skip_serializing_if = "Option::is_none" ) ]
283
- pub vector_aggregator_config_map_name : Option < String > ,
284
-
285
- /// Kafka requires a ZooKeeper cluster connection to run.
286
- /// Provide the name of the ZooKeeper [discovery ConfigMap](DOCS_BASE_URL_PLACEHOLDER/concepts/service_discovery)
287
- /// here. When using the [Stackable operator for Apache ZooKeeper](DOCS_BASE_URL_PLACEHOLDER/zookeeper/)
288
- /// to deploy a ZooKeeper cluster, this will simply be the name of your ZookeeperCluster resource.
289
- pub zookeeper_config_map_name : String ,
290
- }
291
-
292
292
/// Reference to a single `Pod` that is a component of a [`KafkaCluster`]
293
293
///
294
294
/// Used for service discovery.
0 commit comments