关于kafka 我有一个quartz工程 每次连续调用kafka十二小时后 我的客户端就报错

Question

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)

Answer 1

这个问题困扰已久  哪位大神解答必有重谢