This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from dac3e72 [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x
add a4f1174 [FLINK-21059][kafka] KafkaSourceEnumerator does not honor
consumer properties
No new revisions were added by this update.
Summary of changes:
.../flink/connector/kafka/source/KafkaSource.java | 2 +-
.../source/enumerator/KafkaSourceEnumerator.java | 11 +++--
.../source/enumerator/KafkaEnumeratorTest.java | 56 ++++++++++++++++++++--
3 files changed, 61 insertions(+), 8 deletions(-)
