This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a change to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 5dd99ed [FLINK-24281][connectors/kafka] Migrate all format tests from
FlinkKafkaProducer to KafkaSink
new 06d4828 [FLINK-24292][connectors/kafka] Use KafkaSink in examples
instead of FlinkKafkaProducer
new d818ccb [hotfix][connectors/kafka] Rename EventDeSerializer to
EventDeSerializationSchema in examples
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../flink/streaming/kafka/test/KafkaExample.java | 24 ++++++++++++++--------
.../statemachine/KafkaEventsGeneratorJob.java | 17 ++++++++++++---
.../examples/statemachine/StateMachineExample.java | 4 ++--
...alizer.java => EventDeSerializationSchema.java} | 3 ++-
.../kafka/KafkaStandaloneGenerator.java | 4 ++--
5 files changed, 36 insertions(+), 16 deletions(-)
rename
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/statemachine/kafka/{EventDeSerializer.java
=> EventDeSerializationSchema.java} (95%)
