search

FS1360472174 / spark-knowledge

notes for learning spark
0 stars 0 forks source link

consumer bootstrapserver hostname配置错了 #17

Closed FS1360472174 closed 7 years ago

FS1360472174 commented 7 years ago

[2017-10-24 16:31:52,768] ERROR Uncaught exception in herder work thread, exiting: (org.apache.kafka.connect.runtime.distributed.DistributedHerder:205) java.lang.IllegalStateException: Invalid attempt to complete a request future which is already complete at org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:130) at org.apache.kafka.clients.consumer.internals.RequestFuture.raise(RequestFuture.java:140) at org.apache.kafka.clients.consumer.internals.Fetcher.handleListOffsetResponse(Fetcher.java:692) at org.apache.kafka.clients.consumer.internals.Fetcher.access$2100(Fetcher.java:78) at org.apache.kafka.clients.consumer.internals.Fetcher$3.onSuccess(Fetcher.java:636) at org.apache.kafka.clients.consumer.internals.Fetcher$3.onSuccess(Fetcher.java:631) at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:186) at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:149) at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:116) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:493) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:322) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:253) at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:188) at org.apache.kafka.clients.consumer.internals.Fetcher.retrieveOffsetsByTimes(Fetcher.java:408) at org.apache.kafka.clients.consumer.internals.Fetcher.beginningOrEndOffset(Fetcher.java:451) at org.apache.kafka.clients.consumer.internals.Fetcher.endOffsets(Fetcher.java:440) at org.apache.kafka.clients.consumer.KafkaConsumer.endOffsets(KafkaConsumer.java:1490) at org.apache.kafka.connect.util.KafkaBasedLog.readToLogEnd(KafkaBasedLog.java:264) at org.apache.kafka.connect.util.KafkaBasedLog.start(KafkaBasedLog.java:141)