Skip to content

Commit 07fb651

Browse files
Address further comments
Signed-off-by: OwenCorrigan76 <[email protected]>
1 parent f23e2c0 commit 07fb651

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

api/src/main/java/io/strimzi/kafka/access/model/KafkaAccessStatus.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -83,11 +83,11 @@ public void setReadyCondition(final boolean ready, final String message, final S
8383
*
8484
* @return The observed generation.
8585
*/
86-
public Long getObservedGeneration() {
86+
public long getObservedGeneration() {
8787
return observedGeneration;
8888
}
8989

90-
public void setObservedGeneration(Long observedGeneration) {
90+
public void setObservedGeneration(long observedGeneration) {
9191
this.observedGeneration = observedGeneration;
9292
}
9393
}

operator/src/main/java/io/strimzi/kafka/access/KafkaAccessOperator.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,8 @@ public class KafkaAccessOperator {
2626
*/
2727
public static void main(final String[] args) {
2828
LOGGER.info("Kafka Access operator starting");
29-
final Operator operator = new Operator();
29+
final Operator operator = new Operator(overrider -> overrider
30+
.withUseSSAToPatchPrimaryResource(false));
3031
operator.register(new KafkaAccessReconciler(operator.getKubernetesClient()));
3132
operator.start();
3233
Server server = new Server(HEALTH_CHECK_PORT);

0 commit comments

Comments
 (0)