[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-19 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r691969751 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java ## @@ -15

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-19 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r691998884 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java ## @@ -15

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-19 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r691968413 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/metrics/KafkaSourceReaderMetrics.java ## @@ -15

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-18 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r691070993 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-18 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r691070993 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-17 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r690366650 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-17 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r690366650 ## File path: flink-connectors/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReaderTest.java ## @@

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-16 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r689627872 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@ -41

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-16 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r689616706 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@ -41

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-16 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r689531663 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@ -41

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-16 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r689448215 ## File path: flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/connector/kafka/source/reader/KafkaPartitionSplitReader.java ## @@ -16

[GitHub] [flink] fapaul commented on a change in pull request #16838: [FLINK-23801][connector/kafka] Report numBytesIn and pendingRecords in KafkaSource

2021-08-16 Thread GitBox
fapaul commented on a change in pull request #16838: URL: https://github.com/apache/flink/pull/16838#discussion_r689378794 ## File path: flink-test-utils-parent/flink-test-utils-junit/src/main/java/org/apache/flink/core/testutils/CommonTestUtils.java ## @@ -203,10 +203,12 @@ p