This is an automated email from the ASF dual-hosted git repository.
rmetzger pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4a89552 [FLINK-24281][connectors/kafka] Migrate all format tests from
FlinkKafkaProducer to KafkaSink
add a83f8f4 [FLINK-24292][connectors/kafka] Use KafkaSink in examples
instead of FlinkKafkaProducer
add 8664b36 [hotfix][connectors/kafka] Rename EventDeSerializer to
EventDeSerializationSchema in examples
No new revisions were added by this update.
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%)
