View SomeHacks.java
@Producer(valueSerializer = MessageHolderWithTokensSerializer.class)
private SimpleKafkaProducer<String, MessageHolderWithTokens> producer;
View CDIStreamProcessor.java
package net.wessendorf;
import net.wessendorf.kafka.cdi.annotation.KafkaStream;
import org.apache.kafka.streams.kstream.KStream;
import org.apache.kafka.streams.kstream.KTable;
public class StreamProcessor {
@KafkaStream(input = "input_topic", output = "output_topic")
public KStream transformer(final KStream<String, String> source) {
View gist:bc823725af258b036fb265d482295de9
16:20:41,250 WARN [net.wessendorf.kafka.impl.DelegationKafkaConsumer] (EE-ManagedExecutorService-default-Thread-6) Consumer exception: org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition APNsToken_Topic-0 at offset 0
Caused by: org.apache.kafka.common.errors.SerializationException: Unable to deserialize object
Caused by: com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: Unrecognized field "ipAddress" (class org.jboss.aerogear.unifiedpush.message.UnifiedPushMessage), not marked as ignorable (3 known properties: "config", "message", "criteria"])
at [Source: [B@24ba432d; line: 1, column: 1101] (through reference chain: org.jboss.aerogear.unifiedpush.message.holder.MessageHolderWithTokens["unifiedPushMessage"]->org.jboss.aerogear.unifiedpush.message.UnifiedPushMessage["ipAddress"])
at com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException.from(UnrecognizedPropertyException.java:51)
at com.fasterxml.jackson.databind.DeserializationContext
View MessageHolderWithTokensKafkaProducer.java
public class MessageHolderWithTokensKafkaProducer {
@Producer
private SimpleKafkaProducer<String, String> producer;
private final String ADM_TOPIC = "AdmToken_Topic";
private final String APNS_TOPIC = "APNsToken_Topic";
private final String FCM_TOPIC = "FCMToken_Topic";
View Opensift_151_issue.md

Problem with oc cluster up

After installing the latest (1.5.1) to /usr/bin folder, I am getting the following error, when running oc cluster up:

-- Checking container networking ... FAIL
   Error: containers cannot communicate with the OpenShift master
   Details:
     The cluster was started. However, the container networking test failed.
   Solution:
View PseudoFlatPMI.java
FlatPushMessageInformation {
// like currently:
@NotNull
private String pushApplicationId;
private String rawJsonMessage;
private String ipAddress;
private String clientIdentifier;
View config.xml
<?xml version='1.0' encoding='UTF-8'?>
<server xmlns="urn:jboss:domain:1.8">
<extensions>
<extension module="org.jboss.as.clustering.infinispan"/>
<extension module="org.jboss.as.cmp"/>
<extension module="org.jboss.as.connector"/>
<extension module="org.jboss.as.deployment-scanner"/>
<extension module="org.jboss.as.ee"/>
View Client.java
package com.example.blahapp.rest;
import net.wessendorf.kafka.cdi.SimpleKafkaProducer;
import net.wessendorf.kafka.cdi.annotation.Consumer;
import net.wessendorf.kafka.cdi.annotation.KafkaConfig;
import net.wessendorf.kafka.cdi.annotation.Producer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@KafkaConfig(bootstrapServers = "172.17.0.3:9092")
View JUG_MS.adoc

Script: From War to Cloud

Swarm Tool

wget https://repo1.maven.org/maven2/org/wildfly/swarm/swarmtool/2017.4.0/swarmtool-2017.4.0-standalone.jar
java -jar swarmtool-2017.4.0-standalone.jar target/javaee7-simple-sample.war
java -jar javaee7-simple-sample-swarm.jar
View gist:28cd0e7a36037dfd51573045ecd62339
mvn gpg:sign-and-deploy-file \
-Dfile=target/proxy-1.0.0-alpha.1-SNAPSHOT.jar \
-Durl=https://repository.jboss.org/nexus/content/repositories/snapshots/ \
-DpomFile=pom.xml \
-DrepositoryId=jboss-snapshots-repository