luckydarnell commented on issue #108:
URL: https://github.com/apache/rocketmq-flink/issues/108#issuecomment-1878178017
#In idea,every thing is ok,the log:
24/01/05 10:07:16 INFO
org.apache.rocketmq.flink.source.enumerator.RocketMQSourceEnumerator: Starting
the RocketMQSourceEnumerator for consumer group X without periodic partition
discovery.
24/01/05 10:07:16 INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator: Source Source:
s(MQ)- **_registering reader for parallel task 0 @_**
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
thread:MessageQueue [topic=topicx, brokerName=broker-a, queueId=0] has no
committed offset,use Strategy:LATEST instead
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
queue:broker-a-0 start from offset of: 0
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
thread:MessageQueue [topic=topicx, brokerName=broker-a, queueId=2] has no
committed offset,use Strategy:LATEST instead
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
queue:broker-a-2 start from offset of: 0
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
thread:MessageQueue [topic=topicx, brokerName=broker-a, queueId=1] has no
committed offset,use Strategy:LATEST instead
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
queue:broker-a-1 start from offset of: 0
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
thread:MessageQueue [topic=topicx, brokerName=broker-a, queueId=3] has no
committed offset,use Strategy:LATEST instead
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.legacy.common.util.RocketMQUtils: current consumer
queue:broker-a-3 start from offset of: 0
24/01/05 10:07:17 INFO
org.apache.rocketmq.flink.source.enumerator.RocketMQSourceEnumerator: Assigning
splits to readers {0=[[Topic: topicx, Broker: broker-a, Partition: 1,
StartingOffset: 0, StoppingTimestamp: 9223372036854775807], [Topic: topicx,
Broker: broker-a, Partition: 0, StartingOffset: 0, StoppingTimestamp:
9223372036854775807], [Topic: topicx, Broker: broker-a, Partition: 3,
StartingOffset: 0, StoppingTimestamp: 9223372036854775807], [Topic: topicx,
Broker: broker-a, Partition: 2, StartingOffset: 0, StoppingTimestamp:
9223372036854775807]]}
24/01/05 10:07:17 INFO
org.apache.flink.connector.base.source.reader.SourceReaderBase: Adding split(s)
to reader: [[Topic: topicx, Broker: broker-a, Partition: 1, StartingOffset: 0,
StoppingTimestamp: 9223372036854775807], [Topic: topicx, Broker: broker-a,
Partition: 0, StartingOffset: 0, StoppingTimestamp: 9223372036854775807],
[Topic: topicx, Broker: broker-a, Partition: 3, StartingOffset: 0,
StoppingTimestamp: 9223372036854775807], [Topic: topicx, Broker: broker-a,
Partition: 2, StartingOffset: 0, StoppingTimestamp: 9223372036854775807]]
24/01/05 10:07:17 INFO
org.apache.flink.connector.base.source.reader.SourceReaderBase: Reader received
NoMoreSplits event.
24/01/05 10:07:17 INFO
org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher: Starting
split fetcher 0
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
