worker1.sip.com 6700
<http://worker1.sip.com:8000/log?file=squid-66-1572614993%2F6700%2Fworker.log>
java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TimeoutException: Failed to update metadata
after 60000 ms. at
org.apache.kafka.clients.producer.KafkaProducer$FutureFailure.<init>(KafkaProducer.java:730)
at
org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:483)
at
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:430)
at
org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:353)
at org.apache.metron.writer.kafka.KafkaWriter.write(KafkaWriter.java:258)
at
org.apache.metron.writer.BulkWriterComponent.flush(BulkWriterComponent.java:123)
at
org.apache.metron.writer.BulkWriterComponent.applyShouldFlush(BulkWriterComponent.java:179)
at
org.apache.metron.writer.BulkWriterComponent.write(BulkWriterComponent.java:99)
at
org.apache.metron.parsers.bolt.WriterHandler.write(WriterHandler.java:90)
at org.apache.metron.parsers.bolt.WriterBolt.execute(WriterBolt.java:90) at
org.apache.storm.daemon.executor$fn__10195$tuple_action_fn__10197.invoke(executor.clj:735)
at
org.apache.storm.daemon.executor$mk_task_receiver$fn__10114.invoke(executor.clj:466)
at
org.apache.storm.disruptor$clojure_handler$reify__4137.onEvent(disruptor.clj:40)
at
org.apache.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:472)
at
org.apache.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:451)
at
org.apache.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:73)
at
org.apache.storm.daemon.executor$fn__10195$fn__10208$fn__10263.invoke(executor.clj:855)
at org.apache.storm.util$async_loop$fn__1221.invoke(util.clj:484) at
clojure.lang.AFn.run(AFn.java:22) at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.kafka.common.errors.TimeoutException: Failed to
update metadata after 60000 ms.
