2018-03-26 09:01:06.035 [jd-group_mesos-slave-5-1522015280517-f8dcd8cd-leader-finder-thread] INFO? k.c.ConsumerFetcherManager$LeaderFinderThread - [jd-group_mesos-slave-5-1522015280517-f8dcd8cd-leader-finder-thread], Starting?org.springframework.web.client.HttpClientErrorException: 400 Bad Request2018-03-26 09:01:06.035 [jd-group_mesos-slave-5-1521982819626-60c966f7_watcher_executor] INFO? k.c.ZookeeperConsumerConnector - [jd-group_mesos-slave-5-1521982819626-60c966f7], end rebalancing consumer jd-group_mesos-slave-5-1521982819626-60c966f7 try #0 at org.springframework.web.client.DefaultResponseErrorHandler.handleError(DefaultResponseErrorHandler.java:63)2018-03-26 09:01:06.035 [jd-group_mesos-slave-5-1522004445261-fffd10a5_watcher_executor] INFO? k.c.ZookeeperConsumerConnector - [jd-group_mesos-slave-5-1522004445261-fffd10a5], end rebalancing consumer jd-group_mesos-slave-5-1522004445261-fffd10a5 try #0 at org.springframework.web.client.RestTemplate.handleResponse(RestTemplate.java:700) at org.springframework.web.client.RestTemplate.doExecute(RestTemplate.java:653) at org.springframework.web.client.RestTemplate.execute(RestTemplate.java:613) at org.springframework.web.client.RestTemplate.postForObject(RestTemplate.java:380) at com.alert.alertSmas.http.NoticeRestTemplate.postForEmail(NoticeRestTemplate.java:43) at com.alert.alertSmas.kafka.impl.KafkaServiceImpl.sendEmail(KafkaServiceImpl.java:122)2018-03-26 09:01:06.035 [jd-group_mesos-slave-5-1522004445261-fffd10a5-leader-finder-thread] INFO? k.c.ConsumerFetcherManager$LeaderFinderThread - [jd-group_mesos-slave-5-1522004445261-fffd10a5-leader-finder-thread], Starting? at com.alert.alertSmas.quartz.StartRule.execute(StartRule.java:128) at org.quartz.core.JobRunShell.run(JobRunShell.java:202) at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:573)
關于kafka 我有一個quartz工程 每次連續調用kafka十二小時后 我的客戶端就報錯
xiao199441
2018-03-26 14:29:37