this.consumerId=UUID.randomUUID().toString(); | this.pollTimeout=DEFAULT_POLL_TIMEOUT; | UUID.randomUUID().toString() | DEFAULT_POLL_TIMEOUT | flink | 3c93103d1476cb05ec0c018bfa6876e4ecad38e8 | org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 | | _1 | consumerId |
---|
_2 | pollTimeout |
---|
| xyz | UUID.randomUUID().toString() |
---|
| | | AssignedTo | True |