Skip to content

Instantly share code, notes, and snippets.

View scholzj's full-sized avatar
😉
Chop Water, Carry Wood ...

Jakub Scholz scholzj

😉
Chop Water, Carry Wood ...
View GitHub Profile
diff --git a/cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly/KafkaAssemblyOperator.java b/cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly/KafkaAssemblyOperator.java
index 1fd88a77c..a22edda5c 100644
--- a/cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly/KafkaAssemblyOperator.java
+++ b/cluster-operator/src/main/java/io/strimzi/operator/cluster/operator/assembly/KafkaAssemblyOperator.java
@@ -2056,29 +2056,29 @@ public class KafkaAssemblyOperator extends AbstractAssemblyOperator<KubernetesCl
List<String> listenerAddressList = new ArrayList<>(kafkaCluster.getReplicas() + 1);
Future<Void> perListenerFut;
- if (!ListenersUtils.skipCreateBootstrapService(listener)) {
- perListenerFut = Future.succeededFuture();
@scholzj
scholzj / example-http-clients-with-bridge-sidecar.yaml
Created August 15, 2021 21:46
Example HTTP clients with HTTP Bridge sidecar
###############
# Topic
###############
apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
metadata:
name: my-topic
labels:
strimzi.io/cluster: my-cluster
@scholzj
scholzj / kafka-clients.json
Created June 25, 2020 21:06
Kafka Clients Grafana Dashabord
{
"__inputs": [
{
"name": "DS_PROMETHEUS",
"label": "Prometheus",
"description": "",
"type": "datasource",
"pluginId": "prometheus",
"pluginName": "Prometheus"
}
2018-12-10 14:56:20 INFO AbstractAssemblyOperator:258 - Reconciliation #0(watch) Kafka(myproject/my-cluster): Kafka my-cluster in namespace myproject was ADDED
2018-12-10 14:56:20 INFO AbstractAssemblyOperator:152 - Reconciliation #0(watch) Kafka(myproject/my-cluster): Assembly my-cluster should be created or updated
2018-12-10T14:56:20.987+0000: [GC (Allocation Failure) 2018-12-10T14:56:20.988+0000: [DefNew: 34944K->4351K(39296K), 0.0148050 secs] 46736K->18938K(126720K), 0.0153232 secs] [Times: user=0.01 sys=0.00, real=0.01 secs]
2018-12-10 14:56:21 INFO ClusterOperator:168 - ClusterOperator is now ready (health server listening on 8080)
2018-12-10 14:56:21 INFO Main:139 - Cluster Operator verticle started in namespace myproject
2018-12-10 14:56:23 INFO StatefulSetOperator:136 - Rolling update of myproject/my-cluster-zookeeper: Rolling pod my-cluster-zookeeper-0
2018-12-10T14:56:29.994+0000: [GC (Allocation Failure) 2018-12-10T14:56:29.994+0000: [DefNew: 39295K->4351K(39296K), 0.0213601 secs] 53882K->2
@scholzj
scholzj / external.go
Last active October 31, 2018 18:23
SASL EXTERNAL in Go
package main
import (
"fmt"
"qpid.apache.org/electron"
"os"
"crypto/tls"
"io/ioutil"
"crypto/x509"
)
@scholzj
scholzj / temp-throttle.service
Created December 28, 2016 21:48
CPu Throttling service - /etc/systemd/system/temp-throttle.service
[Unit]
Description=Temp Trhottle
[Service]
Type=simple
Restart=always
ExecStart=/root/temp-throttle/temp_throttle.sh 90
[Install]
WantedBy=multi-user.target
@scholzj
scholzj / JmsTransactedReceiverCloseTest.java
Created October 23, 2015 13:48
Closing of receiver on top of tx session
package org.apache.qpid.jms.transactions;
import org.apache.qpid.jms.support.AmqpTestSupport;
import org.junit.Test;
import javax.jms.*;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
@scholzj
scholzj / BroadcastReceiver.cs
Last active September 8, 2015 16:04
Eurex Clearing AMQP Interfaces - Code Examples in AMQP.NET Lite
using System;
using System.Text;
using Amqp;
using Amqp.Sasl;
using Amqp.Framing;
using System.Security.Cryptography.X509Certificates;
using System.Net.Security;
using System.Threading.Tasks;
namespace BroadcastReceiver