You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ar...@apache.org on 2021/08/31 09:29:03 UTC
[flink] branch master updated (db5af67 -> c10bd30)
This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from db5af67 [FLINK-23895][table] Upsert materializer is not inserted for all sink providers
add c10bd30 [FLINK-24051][connectors/kafka] Make groupId optional when constructing a KafkaSource
No new revisions were added by this update.
Summary of changes:
docs/content/docs/connectors/datastream/kafka.md | 1 -
.../connector/kafka/source/KafkaSourceBuilder.java | 10 ++----
.../kafka/source/KafkaSourceBuilderTest.java} | 39 ++++++++--------------
3 files changed, 17 insertions(+), 33 deletions(-)
copy flink-connectors/{flink-connector-jdbc/src/test/java/org/apache/flink/connector/jdbc/DbMetadata.java => flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/KafkaSourceBuilderTest.java} (54%)