部分日志如下：
4/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], Cleared all relevant queues for this fetcher
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], Cleared the data chunks in all the consumer message iterators
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], Committing all offsets after clearing the fetcher queues
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], Releasing partition ownership
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], Consumer mygroupid_TZ0509-1418959450703-1be4114f rebalancing the following partitions: ArrayBuffer(0) for topic luyang with consumers: List(mygroupid_TZ0509-1418959450703-1be4114f-0)
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], mygroupid_TZ0509-1418959450703-1be4114f-0 attempting to claim partition 0
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], mygroupid_TZ0509-1418959450703-1be4114f-0 successfully owned partition 0 for topic luyang
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], Updating the cache
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], Consumer mygroupid_TZ0509-1418959450703-1be4114f selected partitions : luyang:0: fetched offset = -1: consumed offset = -1
14/12/19 11:24:20 INFO consumer.ConsumerFetcherManager$LeaderFinderThread: [mygroupid_TZ0509-1418959450703-1be4114f-leader-finder-thread], Starting
14/12/19 11:24:20 INFO consumer.ZookeeperConsumerConnector: [mygroupid_TZ0509-1418959450703-1be4114f], end rebalancing consumer mygroupid_TZ0509-1418959450703-1be4114f try #0
14/12/19 11:24:20 INFO receiver.ReceiverSupervisorImpl: Called receiver onStart
14/12/19 11:24:20 INFO scheduler.ReceiverTracker: Registered receiver for stream 0 from akka://sparkDriver
14/12/19 11:24:20 INFO kafka.KafkaReceiver: Starting MessageHandler.
14/12/19 11:24:20 INFO utils.VerifiableProperties: Verifying properties
14/12/19 11:24:20 INFO utils.VerifiableProperties: Property metadata.broker.list is overridden to 192.168.103.95:9092,192.168.103.96:9092,192.168.103.97:9092
14/12/19 11:24:20 INFO utils.VerifiableProperties: Property request.timeout.ms is overridden to 30000
14/12/19 11:24:20 INFO utils.VerifiableProperties: Property client.id is overridden to mygroupid
14/12/19 11:24:20 INFO client.ClientUtils$: Fetching metadata from broker id:0,host:192.168.103.95,port:9092 with correlation id 0 for 1 topic(s) Set(luyang)
14/12/19 11:24:20 INFO producer.SyncProducer: Connected to 192.168.103.95:9092 for producing
14/12/19 11:24:20 INFO producer.SyncProducer: Disconnecting from 192.168.103.95:9092
14/12/19 11:24:20 INFO consumer.ConsumerFetcherThread: [ConsumerFetcherThread-mygroupid_TZ0509-1418959450703-1be4114f-0-0], Starting
14/12/19 11:24:20 INFO consumer.ConsumerFetcherManager: [ConsumerFetcherManager-1418959459781] Adding fetcher for partition [luyang,0], initOffset -1 to broker 0 with fetcherId 0
14/12/19 11:24:25 INFO scheduler.ReceiverTracker: Stream 0 received 0 blocks
14/12/19 11:24:25 INFO scheduler.JobScheduler: Added jobs for time 1418959465000 ms
14/12/19 11:24:30 INFO scheduler.ReceiverTracker: Stream 0 received 0 blocks
14/12/19 11:24:30 INFO scheduler.JobScheduler: Added jobs for time 1418959470000 ms
14/12/19 11:24:35 INFO scheduler.ReceiverTracker: Stream 0 received 0 blocks
14/12/19 11:24:35 INFO scheduler.JobScheduler: Added jobs for time 1418959475000 ms
uj5u.com熱心網友回復：
好吧，自己搞定了uj5u.com熱心網友回復：
樓主怎么解決的，我也遇到同樣的問題，能否透露一下解決方案，謝謝！uj5u.com熱心網友回復：
兄弟，你這個是怎么解決的，遇到跟你一樣的問題~
uj5u.com熱心網友回復：
國內的論壇就是和國外的不一樣，我覺得有提出問題的權利，至少應該把解決問題的方法哪怕是思路告知吧，轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/71132.html
標籤：Spark
上一篇：D3D11里面使用多重紋理混合