[jira] [Created] (FLINK-25368) Use AdminClient to get offsets rather than KafkaConsumer

2021-12-17 Thread dengziming (Jira)
dengziming created FLINK-25368: -- Summary: Use AdminClient to get offsets rather than KafkaConsumer Key: FLINK-25368 URL: https://issues.apache.org/jira/browse/FLINK-25368 Project: Flink Issue Ty

[jira] [Created] (FLINK-22526) Rename TopicId to topic in Kafka related code

2021-04-29 Thread dengziming (Jira)
dengziming created FLINK-22526: -- Summary: Rename TopicId to topic in Kafka related code Key: FLINK-22526 URL: https://issues.apache.org/jira/browse/FLINK-22526 Project: Flink Issue Type: Improve

[jira] [Created] (FLINK-17736) Add flink CEP examples

2020-05-15 Thread dengziming (Jira)
dengziming created FLINK-17736: -- Summary: Add flink CEP examples Key: FLINK-17736 URL: https://issues.apache.org/jira/browse/FLINK-17736 Project: Flink Issue Type: Improvement Componen