flink kafkasource 失效

[Frank00w]

kafka 1.1.1
flink 1.14.3

public static void main(String[] args) throws Exception {
StreamExecutionEnvironment evnt = StreamExecutionEnvironment.getExecutionEnvironment();

    KafkaSource<String> Kafka_souerce = KafkaSource.<String>builder()
            .setBootstrapServers("10.16.0.2:9092")
            .setTopics("Flink_cdc_test")
            .setGroupId("0")
            .setStartingOffsets(OffsetsInitializer.earliest())
            .setProperty("transaction.timeout.ms","1000")
            .setValueOnlyDeserializer(new SimpleStringSchema())
            .build();

    DataStreamSource<String> kafka = evnt.fromSource(Kafka_souerce, WatermarkStrategy.noWatermarks(), "kafka").setParallelism(1);

    kafka.print();

    evnt.execute();

13:59:59,080 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Log file environment variable 'log.file' is not set.
13:59:59,082 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'.
13:59:59,763 WARN org.apache.kafka.clients.consumer.ConsumerConfig [] - The configuration 'client.id.prefix' was supplied but isn't a known config.
13:59:59,763 WARN org.apache.kafka.clients.consumer.ConsumerConfig [] - The configuration 'transaction.timeout.ms' was supplied but isn't a known config.
13:59:59,763 WARN org.apache.kafka.clients.consumer.ConsumerConfig [] - The configuration 'partition.discovery.interval.ms' was supplied but isn't a known config.
13:59:59,782 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'key.deserializer' was supplied but isn't a known config.
13:59:59,783 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'value.deserializer' was supplied but isn't a known config.
13:59:59,783 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'enable.auto.commit' was supplied but isn't a known config.
13:59:59,783 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'group.id' was supplied but isn't a known config.
13:59:59,783 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'client.id.prefix' was supplied but isn't a known config.
13:59:59,783 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'transaction.timeout.ms' was supplied but isn't a known config.
13:59:59,783 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'partition.discovery.interval.ms' was supplied but isn't a known config.
13:59:59,783 WARN org.apache.kafka.clients.admin.AdminClientConfig [] - The configuration 'auto.offset.reset' was supplied but isn't a known config.
14:00:00,294 WARN org.apache.kafka.clients.consumer.ConsumerConfig [] - The configuration 'client.id.prefix' was supplied but isn't a known config.
14:00:00,294 WARN org.apache.kafka.clients.consumer.ConsumerConfig [] - The configuration 'transaction.timeout.ms' was supplied but isn't a known config.
14:00:00,294 WARN org.apache.kafka.clients.consumer.ConsumerConfig [] - The configuration 'partition.discovery.interval.ms' was supplied but isn't a known config.

[Frank00w]

无法读取数据