Skip to content

Instantly share code, notes, and snippets.

View Frawless's full-sized avatar

Jakub Stejskal Frawless

  • Red Hat
View GitHub Profile
NAME CLUSTER PARTITIONS REPLICATION FACTOR READY
consumer-offsets---84e7a678d08f4bd226872e5cdd4eb527fadc1c6a my-cluster-987773362 50 3 True
heartbeats my-cluster-1355511146-target 1 1 True
mirrormaker2-cluster-configs my-cluster-1355511146-target 1 1 True
mirrormaker2-cluster-offsets my-cluster-1355511146-target 25 1 True
mirrormaker2-cluster-status my-cluster-1355511146-target 5 1 True
mm2-offse
{
"instant" : {
"epochSecond" : 1614878315,
"nanoOfSecond" : 700549000
},
"thread" : "vert.x-eventloop-thread-0",
"level" : "ERROR",
"loggerName" : "io.strimzi.operator.topic.TopicOperator",
"message" : "Error reconciling KafkaTopic null",
"thrown" : {
[INFO] --- maven-assembly-plugin:3.1.1:single (default) @ api-conversion ---
[INFO] Reading assembly descriptor: src/main/assembly/zip.xml
Downloading from apache: https://repository.apache.org/content/repositories/releases/org/apache/maven/maven-plugin-registry/2.2.0/maven-plugin-registry-2.2.0.pom
Downloading from central: https://repo.maven.apache.org/maven2/org/apache/maven/maven-plugin-registry/2.2.0/maven-plugin-registry-2.2.0.pom
Downloaded from central: https://repo.maven.apache.org/maven2/org/apache/maven/maven-plugin-registry/2.2.0/maven-plugin-registry-2.2.0.pom (1.9 kB at 4.9 kB/s)
Downloading from apache: https://repository.apache.org/content/repositories/releases/org/apache/maven/maven-plugin-api/2.2.0/maven-plugin-api-2.2.0.pom
Downloading from central: https://repo.maven.apache.org/maven2/org/apache/maven/maven-plugin-api/2.2.0/maven-plugin-api-2.2.0.pom
Downloaded from central: https://repo.maven.apache.org/maven2/org/apache/maven/maven-plugin-api/2.2.0/maven-plugin-api-2.2.0.pom (1.5 kB at 1
diff --git a/systemtest/src/test/java/io/strimzi/systemtest/upgrade/StrimziUpgradeST.java b/systemtest/src/test/java/io/strimzi/systemtest/upgrade/StrimziUpgradeST.java
index 95541969f..c6b9055db 100644
--- a/systemtest/src/test/java/io/strimzi/systemtest/upgrade/StrimziUpgradeST.java
+++ b/systemtest/src/test/java/io/strimzi/systemtest/upgrade/StrimziUpgradeST.java
@@ -316,19 +316,17 @@ public class StrimziUpgradeST extends AbstractUpgradeST {
setupEnvAndUpgradeClusterOperator(extensionContext, testParameters, produceMessagesCount, consumeMessagesCount, producerName, consumerName, continuousTopicName, continuousConsumerGroup, "", NAMESPACE);
// Upgrade CO
changeClusterOperator(testParameters, NAMESPACE);
- // Wait for Kafka cluster rolling update
- waitForKafkaClusterRollingUpdate();
apiVersion: v1
items:
- apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
annotations:
kubectl.kubernetes.io/last-applied-configuration: |
{"apiVersion":"kafka.strimzi.io/v1beta1","kind":"Kafka","metadata":{"annotations":{},"name":"my-cluster","namespace":"strimzi-upgrade-test"},"spec":{"entityOperator":{"topicOperator":{},"userOperator":{}},"kafka":{"config":{"inter.broker.protocol.version":"2.7","log.message.format.version":"2.5","offsets.topic.replication.factor":3,"transaction.state.log.min.isr":2,"transaction.state.log.replication.factor":3},"listeners":[{"name":"plain","port":9092,"tls":false,"type":"internal"},{"name":"tls","port":9093,"tls":true,"type":"internal"}],"replicas":3,"storage":{"type":"jbod","volumes":[{"deleteClaim":false,"id":0,"size":"100Gi","type":"persistent-claim"}]},"version":"2.5.0"},"zookeeper":{"replicas":3,"storage":{"deleteClaim":false,"size":"100Gi","type":"persistent-claim"}}}}
creationTimestamp: "2021-03-02T10:11:30Z"
generation: 1
2021-02-24 20:45:55 [ForkJoinPool-1-worker-11] INFO [Exec:172] ======STDOUT END======
2021-02-24 20:45:55 [ForkJoinPool-1-worker-11] INFO [AbstractST:869] ===============================================================
2021-02-24 20:45:55 [ForkJoinPool-1-worker-11] INFO [AbstractST:870] io.strimzi.systemtest.kafka.listeners.ListenersST - [AFTER EACH] has been called
2021-02-24 20:45:55 [ForkJoinPool-1-worker-11] INFO [ResourceManager:255] ############################################################################
2021-02-24 20:45:55 [ForkJoinPool-1-worker-11] INFO [ResourceManager:256] Going to clear all resources for testSendMessagesPlainAnonymous
2021-02-24 20:45:55 [ForkJoinPool-1-worker-11] INFO [ResourceManager:257] ############################################################################
2021-02-24 20:45:55 [ForkJoinPool-1-worker-11] INFO [ResourceManager:191] Delete of Deployment my-cluster-699330499-kafka-clients in namespace listeners
2021-02-24 20:46:11 [ForkJoinPool-1-worker-9] INFO [Re
@Frawless
Frawless / log
Created February 19, 2021 09:30
Namespace Name CPU Requests CPU Limits Memory Requests Memory Limits AGE
--------- ---- ------------ ---------- --------------- ------------- ---
kube-system coredns-5644d7b6d9-k4z2x 100m (5%) 0 (0%) 70Mi (1%) 170Mi (2%) 100m
kube-system etcd-fv-az35-50 0 (0%) 0 (0%) 0 (0%) 0 (0%) 99m
kube-system kube-apiserver-fv-az35-50 250m (12%) 0 (0%) 0 (0%) 0 (0%) 99m
kube-system kube-controller-manager-fv-az35-50 200m (10%) 0 (0%) 0 (0%) 0 (0%) 99m
kube-system kube-proxy-25x9d 0 (0%) 0 (0%) 0 (0%)
@Frawless
Frawless / oom
Created February 18, 2021 15:32
Name: minikube
Roles: master
Labels: beta.kubernetes.io/arch=amd64
beta.kubernetes.io/os=linux
kubernetes.io/arch=amd64
kubernetes.io/hostname=minikube
kubernetes.io/os=linux
minikube.k8s.io/commit=043bdca07e54ab6e4fc0457e3064048f34133d7e
minikube.k8s.io/name=minikube
minikube.k8s.io/updated_at=2021_02_18T09_07_19_0700
------
Generating a RSA private key
.........+++++
.......+++++
} [512 bytes data]
* TLSv1.3 (IN), TLS handshake, Server hello (2):
{ [94 bytes data]
* TLSv1.2 (IN), TLS handshake, Certificate (11):
{ [789 bytes data]
* TLSv1.2 (IN), TLS handshake, Server key exchange (12):
org.opentest4j.AssertionFailedError
at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:35)
at org.junit.jupiter.api.Assertions.fail(Assertions.java:98)
at io.strimzi.systemtest.kafkaclients.clientproperties.AbstractKafkaClientProperties.createKeystore(AbstractKafkaClientProperties.java:289)
at io.strimzi.systemtest.kafkaclients.clientproperties.AbstractKafkaClientProperties$KafkaClientPropertiesBuilder.withSharedProperties(AbstractKafkaClientProperties.java:215)
at io.strimzi.systemtest.kafkaclients.externalClients.BasicExternalKafkaClient.sendMessagesTls(BasicExternalKafkaClient.java:131)
at io.strimzi.systemtest.kafkaclients.externalClients.BasicExternalKafkaClient.sendMessagesTls(BasicExternalKafkaClient.java:98)
at io.strimzi.systemtest.kafka.listeners.ListenersST.testCustomCertLoadBalancerAndTlsRollingUpdate(ListenersST.java:1117)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Nativ