Flink SQL kafka connector有办法获取到partition、offset信息嘛

你好，可以获取 CREATE TABLE KafkaTable ( event_time TIMESTAMP(3) METADATA FROM 'timestamp', partition BIGINT METADATA VIRTUAL, offset BIGINT METADATA VIRTUAL, user_id BIGINT, item_id BIGINT, behavior STRING ) WITH ( 'connector' = 'kafka', 'topic' = 'user_behavior', 'properties.bootstrap.servers' = 'localhost:9092', 'properties.group.id' = 'testGroup', 'scan.startup.mode' = 'earliest-offset', 'format' = 'csv' );

可以查阅官网得到你想要的信息： https://ci.apache.org/projects/flink/flink-docs-release-1.12/dev/table/connectors/kafka.html#available-metadata 希望能帮助到你。*来自志愿者整理的flink邮件归档