scholzj

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

scholzj

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

[Unit]
Description=Temp Trhottle

[Service]
Type=simple
Restart=always
ExecStart=/root/temp-throttle/temp_throttle.sh 90

[Install]
WantedBy=multi-user.target

scholzj

package main

import (
       "fmt"
       "qpid.apache.org/electron"
       "os"
       "crypto/tls"
       "io/ioutil"
       "crypto/x509"
)

scholzj

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

{
  "__inputs": [
    {
      "name": "DS_PROMETHEUS",
      "label": "Prometheus",
      "description": "",
      "type": "datasource",
      "pluginId": "prometheus",
      "pluginName": "Prometheus"
    }

scholzj

###############
# Topic
###############

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
metadata:
  name: my-topic
  labels:
    strimzi.io/cluster: my-cluster

scholzj

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();