Commits

History for

Commits on May 7, 2019

[hotfix][kafka,test] Allow exceptions in KafkaTestEnvironment#prepare
pnowojski
committedMay 7, 2019

Commits on Apr 11, 2019

[FLINK-12100][kafka] Add jaxb-api dependency on Java 9
zentol
committedApr 11, 2019

Commits on Mar 6, 2019

[FLINK-11821] Fix package declaration and location of internal Kafka schema wrappers

lamberken
authored and
aljoscha
committedMar 6, 2019

Commits on Mar 2, 2019

[FLINK-11501] [kafka] Add ratelimiting to Kafka consumer (apache#7679 )

glaksh100
authored and
tweise
committedMar 2, 2019

Commits on Feb 25, 2019

Update version to 1.9-SNAPSHOT
aljoscha
committedFeb 25, 2019

Commits on Feb 22, 2019

[FLINK-8354] Add KafkaDeserializationSchema that uses ConsumerRecord

alexey-tr
authored and
aljoscha
committedFeb 22, 2019
[FLINK-8354] Refactor AUTO_COMMIT config in Kafka consumers

alexey-tr
authored and
aljoscha
committedFeb 22, 2019

Commits on Jan 31, 2019

[FLINK-11064] [table] Setup a new flink-table module structure
twalthr
committedJan 31, 2019

Commits on Jan 30, 2019

[FLINK-11322] [kafka] Use try-with-resource for short-living connections in Kafka connectors

Fokko Driesprong
authored and
tzulitai
committedJan 30, 2019

Commits on Jan 4, 2019

[FLINK-11026][kafka][SQL] Rework kafka sql-client jar creation
zentol
committedJan 4, 2019

Commits on Nov 30, 2018

[FLINK-11015] Remove deprecated code for format-specific Kafka table connectors

yanghua
authored and
twalthr
committedNov 30, 2018

Commits on Nov 19, 2018

[FLINK-10922] Exclude transitive kafka-clients dependency from base flink-connector-kafka
tillrohrmann
committedNov 19, 2018

Commits on Nov 9, 2018

[FLINK-10823][metrics][jmx] Add scala suffix
zentol
committedNov 9, 2018

Commits on Nov 3, 2018

Update version to 1.8-SNAPSHOT
tillrohrmann
committedNov 3, 2018

Commits on Oct 16, 2018

[FLINK-9697] Rename KafkaConsumerCallBridge to KafkaConsumerCallBridge09

yanghua
authored and
aljoscha
committedOct 16, 2018
[FLINK-9697] Rename KafkaTableSink to KafkaTableSinkBase

yanghua
authored and
aljoscha
committedOct 16, 2018
[FLINK-9697] Rename KafkaTableSource to KafkaTableSourceBase

yanghua
authored and
aljoscha
committedOct 16, 2018

Commits on Aug 1, 2018

[FLINK-9979] [table] Support a FlinkKafkaPartitioner for Kafka table sink factory
twalthr
committedAug 1, 2018

Commits on Jul 23, 2018

[FLINK-9846] [table] Add a Kafka table sink factory
twalthr
committedJul 23, 2018

Commits on Jul 20, 2018

[FLINK-9886] [sql-client] Build SQL jars with every build
twalthr
committedJul 20, 2018
[FLINK-9852] [table] Expose descriptor-based sink creation and introduce update mode
twalthr
committedJul 20, 2018

Commits on Jul 16, 2018

Update version to 1.7-SNAPSHOT
tillrohrmann
committedJul 16, 2018

Commits on Jul 15, 2018

[FLINK-8866] [table] Merge table source/sink/format factories
twalthr
committedJul 15, 2018
[FLINK-8866] [table] Create unified interfaces to configure and instatiate TableSinks

Shuyi Chen
authored and
twalthr
committedJul 15, 2018
[FLINK-8558] [table] Add unified format interfaces and separate formats from connectors
twalthr
committedJul 15, 2018

Commits on Jun 29, 2018

[FLINK-9217][kafka-tests] Ignore testTimestamps for Kafka 0.10
pnowojski
committedJun 29, 2018

Commits on May 4, 2018

[FLINK-9292] [core] Remove TypeInfoParser (part 1)
StephanEwen
committedMay 4, 2018

Commits on Apr 24, 2018

[FLINK-8537] [table] Add a Kafka table source factory with Avro format support

xccui
authored and
twalthr
committedApr 24, 2018

Commits on Apr 6, 2018

[hotfix][tests] Remove Kafka testFailOnDeploy test
zentol
committedApr 6, 2018

Commits on Mar 2, 2018

[FLINK-6352] [kafka] Further improvements for timestamped-based startup mode
tzulitai
committedMar 2, 2018
[FLINK-6352] [kafka] Support to set offset of Kafka with specific date

FangYongs
authored and
tzulitai
committedMar 2, 2018

Commits on Feb 27, 2018

[FLINK-8538] [table] Improve unified table sources
twalthr
committedFeb 27, 2018
[FLINK-8538][table]Add a Kafka table source factory with JSON format support

xccui
authored and
twalthr
committedFeb 27, 2018
Update version to 1.6-SNAPSHOT
tillrohrmann
committedFeb 27, 2018

Commits on Feb 15, 2018

[FLINK-8630] [formats] Add proper support for JSON formats
twalthr
committedFeb 15, 2018