java storm tick ack_java – Storm KafkaSpout停止使用来自Kafka主题的消息

左手的ㄟ右手 2022-11-03 11:28 10阅读 0赞

2016-07-05 03:58:26.097 o.a.s.d.task \[INFO\] Emitting: packet\_spout \_\_metrics \[\#object\[org.apache.storm.metric.api.IMetricsConsumer$TaskInfo 0x2c35b34f “org.apache.storm.metric.api.IMetricsConsumer$TaskInfo@2c35b34f”\] \[\#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x798f1e35 “\[\_\_ack-count = \{default=0\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x230867ec “\[\_\_sendqueue = \{sojourn\_time\_ms=0.0, write\_pos=5411461, read\_pos=5411461, overflow=0, arrival\_rate\_secs=0.0, capacity=1024, population=0\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x7cdec8eb “\[\_\_complete-latency = \{default=0.0\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x658fc59 “\[\_\_skipped-max-spout = 0\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x3c1f3a50 “\[\_\_receive = \{sojourn\_time\_ms=4790.5, write\_pos=2468305, read\_pos=2468304, overflow=0, arrival\_rate\_secs=0.20874647740319383, capacity=1024, population=1\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x262d7906 “\[\_\_skipped-inactive = 0\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x73648c7e “\[kafkaPartition = \{Partition\{host=slave103:9092, topic=packet, partition=12\}/fetchAPICallCount=0, Partition\{host=slave103:9092, topic=packet, partition=12\}/fetchAPILatencyMax=null, Partition\{host=slave103:9092, topic=packet, partition=12\}/lostMessageCount=0, Partition\{host=slave103:9092, topic=packet, partition=12\}/fetchAPILatencyMean=null, Partition\{host=slave103:9092, topic=packet, partition=12\}/fetchAPIMessageCount=0\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x4e43df61 “\[kafkaOffset = \{packet/totalLatestCompletedOffset=154305947, packet/partition\_12/spoutLag=82472754, packet/totalEarliestTimeOffset=233919465, packet/partition\_12/earliestTimeOffset=233919465, packet/partition\_12/latestEmittedOffset=154307691, packet/partition\_12/latestTimeOffset=236778701, packet/totalLatestEmittedOffset=154307691, packet/partition\_12/latestCompletedOffset=154305947, packet/totalLatestTimeOffset=236778701, packet/totalSpoutLag=82472754\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x49fe816b “\[\_\_transfer-count = \{\_\_ack\_init=0, default=0, \_\_metrics=0\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x63e2bdc0 “\[\_\_fail-count = \{\}\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x3b17bb7b “\[\_\_skipped-throttle = 1086120\]”\] \#object\[org.apache.storm.metric.api.IMetricsConsumer$DataPoint 0x1315a68c “\[\_\_emit-count = \{\_\_ack\_init=0, default=0, \_\_metrics=0\}\]”\]\]\]

2016-07-05 03:58:55.042 o.a.s.d.executor \[INFO\] Processing received message FOR -2 TUPLE: source: \_\_system:-1, stream: \_\_tick, id: \{\}, \[30\]

2016-07-05 03:59:25.042 o.a.s.d.executor \[INFO\] Processing received message FOR -2 TUPLE: source: \_\_system:-1, stream: \_\_tick, id: \{\}, \[30\]

2016-07-05 03:59:25.946 o.a.s.d.executor \[INFO\] Processing received message FOR -2 TUPLE: source: \_\_system:-1, stream: \_\_metrics\_tick, id: \{\}, \[60\]