Argh ... I wanted to propose a Kafka Connect and not a Kafka Steam adapter (
By the way my currently most used setup is actually using PLC4X for PLC
communication and using Edgents Kafka Connector to publish to Kafka.
A Kafka Connect adapter would allow to directly connect it to Kafka.
Am 13.03.18, 00:02 schrieb "hedh...@gmail.com im Auftrag von Niclas Hedhman"
<hedh...@gmail.com im Auftrag von nic...@hedhman.org>:
I have some Kafka experience, but not used Kafka Streams. But I think the
most straight forward approach would still be to have a Kafka Producer on
the PLC4X side simply writing to one or more Kafka topics, which is
You need to 'configure' during the instance creation;
Properties properties = new Properties();
properties.put( ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, cli.kafka );
properties.put( ProducerConfig.LINGER_MS_CONFIG, 1 );
KafkaProducer<String, String> producer = new KafkaProducer<>( properties );
And once you have the producer, you can push a message to the topic with or
without a key, like this;
producer.send( new ProducerRecord<>( "your-topic", value ) );
I am pretty sure Kafka Streams can take over from the topic queue.
On Mon, Mar 12, 2018 at 10:38 PM, Christofer Dutz <christofer.d...@c-ware.de
> last week I attended the Kafka meetup of a colleague of mine and in his
> talk he introduced Kafka Streams and to me it sounded like a „Clustered
> My second thought was: would it not be cool to implement such a Kafka
> Stream Connector?
> Anyone here got the knowhow to do that? Shouldn’t be that difficult.
Niclas Hedhman, Software Developer
http://polygene.apache.org - New Energy for Java