The things I would try would first in you are you class Person and Address have
getters and setters and a no argument constructor.
From: Wouter Zorgdrager [mailto:zorgdrag...@gmail.com]
Sent: Wednesday, April 25, 2018 7:17 AM
To: user@flink.apache.org
Subject: KafkaProducer with generic (Avro) se
We had a similar issue and it turns out the flink kafka connector doesn’t honor
the groupID. This resulted in multiple consumers getting partial events
(basically load balanced between my multiple consumers).
See
https://stackoverflow.com/questions/38639019/flink-kafka-consumer-groupid-not-worki
Is there any good documentation on building a flink source connector. I need to
build on for AMPS.
This message contains confidential information and is intended only for the
individual named. If you are not the named addressee, you should not
disseminate, distribute, alter or copy this e-mail
in getting the log
messages I was expecting, thus actually processing.
From: Nortman, Bill [mailto:william.nort...@pimco.com]
Sent: Thursday, April 19, 2018 2:51 PM
To: 'user@flink.apache.org'
Subject: CEP Debugging
So I have events coming in in this format
TransactionID, Micros
So I have events coming in in this format
TransactionID, MicroserviceName, Direction,EpochTimeStamp.
For each call to a microservice and event is generates with a timestamp with
direction of "in". Then when completed it generates with a timestamp with
direction of "out".
I need to calculate laten
