Skip to content

Instantly share code, notes, and snippets.

View rareddy's full-sized avatar

Ramesh Reddy rareddy

33 followers · 0 following
  • Red Hat
View GitHub Profile
@rareddy
rareddy / gist:015e7a502c2912942d055bd37ae83c01
Created April 4, 2024 20:49
-----BEGIN CERTIFICATE-----
MIIDkTCCAnmgAwIBAgIUSkoHMI0ABmtyw8m2HJWGRgDP6PUwDQYJKoZIhvcNAQEL
BQAwWDEbMBkGA1UECgwSbW9kZWxyZWdpc3RyeSBJbmMuMTkwNwYDVQQDDDBhcHBz
LnJvc2EucmFyZWRkeS1yb3NhLnZndHkucDMub3BlbnNoaWZ0YXBwcy5jb20wHhcN
MjQwNDAzMjIxNDAxWhcNMjUwNDAzMjIxNDAxWjBYMRswGQYDVQQKDBJtb2RlbHJl
Z2lzdHJ5IEluYy4xOTA3BgNVBAMMMGFwcHMucm9zYS5yYXJlZGR5LXJvc2Eudmd0
eS5wMy5vcGVuc2hpZnRhcHBzLmNvbTCCASIwDQYJKoZIhvcNAQEBBQADggEPADCC
AQoCggEBAKisIGTNKSkLBWgfCCxHKzaZsiSsD0ghKDwdPCzHY8L9eV1Uxi72O3J1
I2TefwfQDl0Gpd8BXRL85DL/cbml/YwYlphhglBniDNOk+6YWz+8lfn+B1jX7zPJ
i8x3FFHHC40vSQdIsmiR7MowJzYPbpIYQifgH9A3TBwEM4DHN6F5gHzlE6e9Jut5
@rareddy
rareddy / gist:d2f7045f0f18fe84011a0320233e86d6
Created September 23, 2022 18:33
apiVersion: managedkafka.bf2.org/v1alpha1
kind: ManagedKafkaAgent
metadata:
creationTimestamp: '2022-09-23T13:53:23Z'
generation: 2
managedFields:
- apiVersion: managedkafka.bf2.org/v1alpha1
fieldsType: FieldsV1
fieldsV1:
'f:status':
@rareddy
rareddy / gist:e586f520085bc21a8522bd61b7e19f9b
Created September 23, 2022 18:23
kind: Pod
apiVersion: v1
metadata:
generateName: reserved-kafka-standard-1-kafka-6ff9f8765c-
annotations:
k8s.v1.cni.cncf.io/network-status: |-
[{
"name": "openshift-sdn",
"interface": "eth0",
"ips": [
@rareddy
rareddy / gist:286c41eaf086281e2b6ec9ca0d8ed282
Created September 23, 2022 17:05
2022-09-23 17:03:17,804 INFO [org.bf2.ope.con.ManagedKafkaController] (EventHandler-managedkafkacontroller) mk.id=reserved-kafka-standard-1 Updating Kafka instance reserved-kafka-standard-1/reserved-kafka-standard-1 436626
2022-09-23 17:03:17,958 ERROR [io.jav.ope.pro.eve.ReconciliationDispatcher] (EventHandler-managedkafkacontroller) Error during event processing ExecutionScope{ resource id: CustomResourceID{name='reserved-kafka-standard-1', namespace='reserved-kafka-standard-1'}, version: 436626} failed.: io.fabric8.kubernetes.client.KubernetesClientException: Failure executing: PUT at: https://172.30.0.1/apis/apps/v1/namespaces/reserved-kafka-standard-1/deployments/reserved-kafka-standard-1-zookeeper. Message: Deployment.apps "reserved-kafka-standard-1-zookeeper" is invalid: spec.selector: Invalid value: v1.LabelSelector{MatchLabels:map[string]string{"app":"reserved-kafka-standard-1-zookeeper", "app.kubernetes.io/managed-by":"kas-fleetshard-operator"}, MatchExpressions:[]v1.LabelSelectorRequirement(nil)}
@rareddy
rareddy / gist:a2d0518f5b9585e91e5bfe51991f2ccc
Created June 16, 2022 20:23
kind: StatefulSet
apiVersion: apps/v1
metadata:
annotations:
strimzi.io/kafka-version: 3.0.1
strimzi.io/storage: >-
{"volumes":[{"type":"persistent-claim","size":"388184932309","class":"gp2","deleteClaim":true,"id":0}],"type":"jbod"}
resourceVersion: '464927475'
name: mk-e2e-ll-e2e-stage-kafka
uid: be2ad9b8-c589-4637-899f-6fe983717ec7
@rareddy
rareddy / gist:aa484ef2ef8b9751f9d1039b46e2b261
Last active March 28, 2022 20:15
apiVersion: managedkafka.bf2.org/v1alpha1
kind: ManagedKafka
metadata:
name: demo
namespace: demo
spec:
capacity:
egressPerSec: 30Mi
ingressEgressThroughputPerSec: 30Mi
ingressPerSec: 30Mi
@rareddy
rareddy / gist:97c02fb472594072a65f98207157887b
Created March 15, 2022 23:02
package org.bf2.performance;
import org.apache.kafka.clients.admin.Admin;
import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;
import java.io.IOException;
import java.nio.file.Path;
import java.nio.file.Paths;
@rareddy
rareddy / gist:24f9d9739b350ba67bbfb87b4ff7a7ee
Created January 6, 2022 19:28
hese entries have been added to quay.io/mk-ci-cd/kafka-27@sha256:e1c5a55dcad0bf0ef5003ed760030bac2196f0ea911e1f0b4d85a9401ef986f7:
FILE SIZE
/kafka_2.12-2.7.0.managedsvc-redhat-00006 0
/opt/kafka/libs/connect-api-2.7.0.managedsvc-redhat-00006.jar 101.2K
/opt/kafka/libs/connect-basic-auth-extension-2.7.0.managedsvc-redhat-00006.jar 20.2K
/opt/kafka/libs/connect-file-2.7.0.managedsvc-redhat-00006.jar 19.5K
/opt/kafka/libs/connect-json-2.7.0.managedsvc-redhat-00006.jar 44.3K
/opt/kafka/libs/connect-mirror-2.7.0.managedsvc-redhat-00006.jar 93.8K
/opt/kafka/libs/connect-mirror-client-2.7.0.managedsvc-redhat-00006.jar 27.8K
/opt/kafka/libs/connect-runtime-2.7.0.managedsvc-redhat-00006.jar 599.3K
@rareddy
rareddy / gist:e9750534cf73595d9b8139dbc9c2d3c2
Created November 5, 2021 13:59
kind: Deployment
apiVersion: apps/v1
metadata:
name: dummy
namespace: test
uid: 22158c09-6702-4179-8291-133b9fd3c864
resourceVersion: '914245'
generation: 1
creationTimestamp: '2021-11-05T13:54:31Z'
annotations:
@rareddy
rareddy / gist:774819f2503f0f82a90025384558a64f
Created September 17, 2021 17:52
diff --git a/operator/src/main/java/org/bf2/operator/operands/KafkaCluster.java b/operator/src/main/java/org/bf2/operator/operands/KafkaCluster.java
index 734c46b..1a6c2fb 100644
--- a/operator/src/main/java/org/bf2/operator/operands/KafkaCluster.java
+++ b/operator/src/main/java/org/bf2/operator/operands/KafkaCluster.java
@@ -356,7 +356,7 @@
PodTemplateBuilder podTemplateBuilder = new PodTemplateBuilder()
.withAffinity(affinityBuilder.build())
.withImagePullSecrets(imagePullSecretManager.getOperatorImagePullSecrets(managedKafka))
- .withTopologySpreadConstraints(azAwareTopologySpreadConstraint(managedKafka.getMetadata().getName() + "-kafka"));
+ .withTopologySpreadConstraints(azAwareTopologySpreadConstraint(managedKafka.getMetadata().getName() + "-kafka", "DoNotSchedule"));