View gist:b40f8c835ed5f16f1fc729901305a958
oc exec -it my-cluster-kafka-0 -- bin/kafka-topics.sh --zookeeper my-cluster-zookeeper:2181 --list
View ProducerBuilder.java
package org.apache.kafka.clients.producer;
import org.apache.kafka.clients.producer.internals.DefaultPartitioner;
import org.apache.kafka.common.metrics.MetricsReporter;
import org.apache.kafka.common.serialization.IntegerSerializer;
import org.apache.kafka.common.serialization.Serializer;
import org.apache.kafka.common.serialization.StringSerializer;
import java.util.List;
import java.util.Properties;
View gist:0f4d1903c045ece1c98da35f344e18e7
##############################################################################
## Provision mj-cool
## This role executes much of the needed functionality to provision an
## application using an Ansible Playbook Bundle. Included in the comments
## below are some sample resources for getting started deploying an application
## to OpenShift.
##############################################################################
##############################################################################
View hrm.md

This:

        final HttpServer server = vertx.createHttpServer();
        final Flowable<HttpServerRequest> requestFlowable = server.requestStream().toFlowable();

or

that:

View Foo.java
final ProducerRecord
public ProducerRecord(String topic, K key, V value, Iterable<Header> headers)
View client.http.md
        HttpClient client = vertx.createHttpClient();

        CloudEvent<Map<String, String>> ce = null;

        client.post("http://mycloud.com/channel")
                .putHeader("Content-Type", MimeMapping.getMimeTypeForExtension("json"))
                .end(Json.decodeValue((Buffer) ce, new TypeReference<CloudEvent<Map<String, String>>>() {} ));
View travis_log.txt
$ export JAVA_HOME=$HOME/openjdk11
$ bash install-jdk.sh -F 11 -L GPL --target $JAVA_HOME --workspace $HOME/.cache/install-jdk
install-jdk.sh 2018-06-01
Variables:
feature = 11
license = GPL
os = linux-x64
url = https://download.java.net/java/early_access/jdk11/18/GPL/openjdk-11-ea+18_linux-x64_bin.tar.gz
status = 200
archive = /home/travis/.cache/install-jdk/openjdk-11-ea+18_linux-x64_bin.tar.gz
View snippet.java
// given
final Map<String, Object> storagePayload = (MAPPER.readValue(Thread.currentThread().getContextClassLoader().getResourceAsStream("pvc.json"), Map.class));
final CloudEvent<Map<String, Object>> storageCloudEventWrapper = new CloudEventBuilder<Map<String, Object>>()
.eventType("ProvisioningSucceeded")
.eventTypeVersion("2.0")
.source(URI.create("/scheduler"))
.eventID(UUID.randomUUID().toString())
.data(storagePayload)
.build();
View storageEvent.json
{
"eventType" : "ProvisioningSucceeded",
"cloudEventsVersion" : "0.1",
"source" : "/scheduler",
"eventID" : "3a3ae5fb-df25-4df4-81a1-bcbe0cc441c5",
"data" : {
"apiVersion" : "v1",
"kind" : "PersistentVolumeClaim",
"metadata" : {
"name" : "gluster-default-volume"
View RxHttp.md

Reading cloud event with reactivex and vertx:

    @Override
    public void start() throws Exception {

        final HttpServer server = vertx.createHttpServer();
        final Flowable<HttpServerRequest> requestFlowable = server.requestStream().toFlowable();

        requestFlowable.subscribe(httpServerRequest -> {