View gist:959c5811ca8687994f03ca13b0f95d95
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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(); |
View example-http-clients-with-bridge-sidecar.yaml
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
############### | |
# Topic | |
############### | |
apiVersion: kafka.strimzi.io/v1beta2 | |
kind: KafkaTopic | |
metadata: | |
name: my-topic | |
labels: | |
strimzi.io/cluster: my-cluster |
View kafka-clients.json
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
{ | |
"__inputs": [ | |
{ | |
"name": "DS_PROMETHEUS", | |
"label": "Prometheus", | |
"description": "", | |
"type": "datasource", | |
"pluginId": "prometheus", | |
"pluginName": "Prometheus" | |
} |
View gist:9a773f6616fab4debcc878d32a6e37f6
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |
View external.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
package main | |
import ( | |
"fmt" | |
"qpid.apache.org/electron" | |
"os" | |
"crypto/tls" | |
"io/ioutil" | |
"crypto/x509" | |
) |
View temp-throttle.service
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
[Unit] | |
Description=Temp Trhottle | |
[Service] | |
Type=simple | |
Restart=always | |
ExecStart=/root/temp-throttle/temp_throttle.sh 90 | |
[Install] | |
WantedBy=multi-user.target |
View JmsTransactedReceiverCloseTest.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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; |
View BroadcastReceiver.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 |