kafka傳送訊息出現的問題KafKa error java.nio.channels.UnresolvedAddressException
出現以下的錯
124 [main] INFO kafka.utils.VerifiableProperties - Verifying properties
157 [main] INFO kafka.utils.VerifiableProperties - Property compression.codec is overridden to 1
157 [main] INFO kafka.utils.VerifiableProperties - Property metadata.broker.list is overridden to 112.74.109.244:9092
157 [main] INFO kafka.utils.VerifiableProperties - Property producer.type is overridden to async
157 [main] INFO kafka.utils.VerifiableProperties - Property serializer.class is overridden to kafka.serializer.StringEncoder
158 [main] WARN kafka.utils.VerifiableProperties - Property zk.connect is not valid
203 [main] INFO kafka.producer.Producer - Shutting down producer
204 [main] INFO kafka.producer.async.ProducerSendThread - Begin shutting down ProducerSendThread
272 [ProducerSendThread-] INFO kafka.client.ClientUtils$ - Fetching metadata from broker id:0,host:112.74.109.244,port:9092 with correlation id 0 for 1 topic(s) Set(order)
293 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Connected to 112.74.109.244:9092 for producing
327 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Disconnecting from 112.74.109.244:9092
2629 [ProducerSendThread-] ERROR kafka.producer.SyncProducer - Producer connection to iZ943qtt41eZ:9092 unsuccessful
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
2640 [ProducerSendThread-] WARN kafka.producer.async.DefaultEventHandler - Failed to send producer request with correlation id 2 to broker 0 with data for partitions [order,0]
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
2651 [ProducerSendThread-] INFO kafka.producer.async.DefaultEventHandler - Back off for 100 ms before retrying send. Remaining retries = 3
2754 [ProducerSendThread-] INFO kafka.client.ClientUtils$ - Fetching metadata from broker id:0,host:112.74.109.244,port:9092 with correlation id 3 for 1 topic(s) Set(order)
2769 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Connected to 112.74.109.244:9092 for producing
3094 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Disconnecting from 112.74.109.244:9092
3098 [ProducerSendThread-] ERROR kafka.producer.SyncProducer - Producer connection to iZ943qtt41eZ:9092 unsuccessful
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
3101 [ProducerSendThread-] WARN kafka.producer.async.DefaultEventHandler - Failed to send producer request with correlation id 5 to broker 0 with data for partitions [order,0]
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
3103 [ProducerSendThread-] INFO kafka.producer.async.DefaultEventHandler - Back off for 100 ms before retrying send. Remaining retries = 2
3203 [ProducerSendThread-] INFO kafka.client.ClientUtils$ - Fetching metadata from broker id:0,host:112.74.109.244,port:9092 with correlation id 6 for 1 topic(s) Set(order)
3220 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Connected to 112.74.109.244:9092 for producing
3541 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Disconnecting from 112.74.109.244:9092
3544 [ProducerSendThread-] ERROR kafka.producer.SyncProducer - Producer connection to iZ943qtt41eZ:9092 unsuccessful
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
3546 [ProducerSendThread-] WARN kafka.producer.async.DefaultEventHandler - Failed to send producer request with correlation id 8 to broker 0 with data for partitions [order,0]
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
3547 [ProducerSendThread-] INFO kafka.producer.async.DefaultEventHandler - Back off for 100 ms before retrying send. Remaining retries = 1
3648 [ProducerSendThread-] INFO kafka.client.ClientUtils$ - Fetching metadata from broker id:0,host:112.74.109.244,port:9092 with correlation id 9 for 1 topic(s) Set(order)
6661 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Connected to 112.74.109.244:9092 for producing
9698 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Disconnecting from 112.74.109.244:9092
9702 [ProducerSendThread-] ERROR kafka.producer.SyncProducer - Producer connection to iZ943qtt41eZ:9092 unsuccessful
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
9705 [ProducerSendThread-] WARN kafka.producer.async.DefaultEventHandler - Failed to send producer request with correlation id 11 to broker 0 with data for partitions [order,0]
java.nio.channels.UnresolvedAddressException: null
at sun.nio.ch.Net.checkAddress(Net.java:29) ~[na:1.6.0_43]
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:512) ~[na:1.6.0_43]
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply$mcV$sp(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1$$anonfun$apply$mcV$sp$1.apply(SyncProducer.scala:102) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply$mcV$sp(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer$$anonfun$send$1.apply(SyncProducer.scala:101) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.metrics.KafkaTimer.time(KafkaTimer.scala:33) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.SyncProducer.send(SyncProducer.scala:100) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$send(DefaultEventHandler.scala:255) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:106) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler$$anonfun$dispatchSerializedData$2.apply(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap$$anonfun$foreach$1.apply(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at scala.collection.Iterator$class.foreach(Iterator.scala:772) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$$anon$1.foreach(HashTable.scala:157) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashTable$class.foreachEntry(HashTable.scala:190) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreachEntry(HashMap.scala:45) [scala-library-2.9.2.jar:na]
at scala.collection.mutable.HashMap.foreach(HashMap.scala:95) [scala-library-2.9.2.jar:na]
at kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:100) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:72) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
9706 [ProducerSendThread-] INFO kafka.producer.async.DefaultEventHandler - Back off for 100 ms before retrying send. Remaining retries = 0
9807 [ProducerSendThread-] INFO kafka.client.ClientUtils$ - Fetching metadata from broker id:0,host:112.74.109.244,port:9092 with correlation id 12 for 1 topic(s) Set(order)
9821 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Connected to 112.74.109.244:9092 for producing
10137 [ProducerSendThread-] INFO kafka.producer.SyncProducer - Disconnecting from 112.74.109.244:9092
10138 [ProducerSendThread-] ERROR kafka.producer.async.DefaultEventHandler - Failed to send requests for topics order with correlation ids in [0,12]
10139 [ProducerSendThread-] ERROR kafka.producer.async.ProducerSendThread - Error in handling batch of 1 events
kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90) ~[kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:93) [kafka_2.9.2-0.8.1.1.jar:na]
at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) [kafka_2.9.2-0.8.1.1.jar:na]
10139 [main] INFO kafka.producer.async.ProducerSendThread - Shutdown ProducerSendThread complete
10139 [main] INFO kafka.producer.ProducerPool - Closing all sync producers
這問題搞了我很多久，主要沒仔細看日誌，當我認真看時，注要看到一句 kafka.producer.SyncProducer - Producer connection to iZ943qtt41eZ:9092 unsuccessful
然後我就想這應是識別不了主機名的原因，然後在 hosts檔案上加上就可以了。當不知為什麼他要用主機名，明明我是用了IP的
另一個錯是消費者裡報的：ERROR backtype.storm.daemon.executor - java.lang.NoClassDefFoundError: org/I0Itec/zkclient/serialize/ZkSerializer
找不到檔案，這是在zkclient.jar裡，加上就行了，下載地址如下：
http://repo1.maven.org/maven2/com/101tec/zkclient/0.1.0/zkclient-0.1.0.jar
相關推薦
kafka傳送訊息出現的問題KafKa error java.nio.channels.UnresolvedAddressException
出現以下的錯 124 [main] INFO kafka.utils.VerifiableProperties - Verifying properties 157 [main] INFO kafka.utils.VerifiableProperties - Pr
activemq報警告java.nio.channels.UnresolvedAddressException
activemq叢集啟動一直報警告： 2018-08-23 22:13:04,153 | WARN | Unexpected session error: java.io.IOException: java.nio.channels.UnresolvedAddressException
java操作kafka傳送訊息和接收訊息
<!-- java程式的Kakfa--> <dependency> <groupId>org.apache.kafka</groupId>
java 連接Kafka報錯java.nio.channels.ClosedChannelExcep
img 由於 客戶端 客戶端訪問 主機名 ava 技術分享 gin color Java 客戶端連接Kafka報如下錯誤 java.nio.channels.ClosedChannelExcep 是由於Kafka server.properties中的advertised.
Kafka傳送訊息過程
Kafka傳送訊息模型 ProducerRecord物件包含目標主題和要傳送的內容，還可以指定鍵或分割槽。傳送ProducerRecord物件時，生產者要先把鍵和值物件序列化為位元組陣列（預設使用StringSerialize
SPRING 整合 KAFKA 傳送訊息
準備工作 1.安裝kafka+zookeeper環境 2.利用命令建立好topic，建立一個topic my-topic 整合步驟 1.配置生產者 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns=
kafka傳送訊息失敗的原因
2017-10-08 00:30:52.765 [pool-1-thread-1] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka v
Flume 採集傳送訊息到kafka
一些場景需要採集文字內容傳送到kafka，flume正好提供了這種解決方案 Flume agent指令碼及配置如下 Mac 安裝：
idea出現：error:java: Target level '1.7' is incompatible with source level '1.8'.解決辦法
tin get 技術 strong mark 更改 ID HR ati 當我們開始使用idea的時候，編譯jsp程序我們有可能出現編譯錯誤，然而我們的代碼又沒有什麽問題。 解決方法一：我們開始的時候可以通過修改java compiler來解決這樣的問題，點擊file菜
Intellij idea 出現錯誤 error:java: 無效的源發行版: 8解決方法
圖片 jpg tag spa pom apach bubuko 1.8 maven項目 這是由於jdk的版本與項目的要求不一致造成的，如果是maven項目，首先查看一下pom.xml,以我的項目為例： <build> <plugin
Error:java.nio.file.DirectoryNotEmptyException，有可能是重名了
Error:java.nio.file.DirectoryNotEmptyException: E:\AndroidStudio\AndroidTestDemo\gaopeng\build\intermediates\assets\anzhi\debug\emoji Er
idea出現：error:java: Target level '1.7' is incompatible with source level '1.8'.解決辦法
當我們開始使用idea的時候，編譯jsp程式我們有可能出現編譯錯誤，然而我們的程式碼又沒有什麼問題。 解決方法一：我們開始的時候可以通過修改java compiler來解決這樣的問題，點選file選
Spark2 Failed to send RPC 5346982634 to /ns1:58312: java.nio.channels.ClosedChannelException
將spark任務執行與yarn上出現以下錯誤： scala> 18/11/21 16:20:11 ERROR cluster.YarnClientSchedulerBackend: Yarn application has already exited with state FINISHE
com.alibaba.dubbo.remoting.RemotingException: Caused by: java.nio.channels.ClosedChannelException
生產遇到的一個異常如下： com.alibaba.dubbo.remoting.RemotingException: Failed to send message Response [id=0, version=2.0.0, status=20, event=false, error=nul
Solr索引檔案被鎖 java.nio.channels.OverlappingFileLockException
昨天把部落格上線，今天早上起來發現昨天晚上Solr伺服器出錯了，到今天下午才有時間來解決，一個Tomcat放部落格專案，另一個Tomcat放Solr伺服器，配置了多個Solr Core，第一次重啟Solr伺服器所在的Tomcat，報錯資訊如下。 2018-05-18 14:
solr啟動時報錯java.nio.channels.OverlappingFileLockException
2011-5-10 10:12:41 org.apache.solr.servlet.SolrDispatchFilter init 嚴重: Could not start SOLR. Check solr/home property java.nio.channels.OverlappingFileLock
storm 報錯：java.nio.channels.ClosedChannelException: null
STORM叢集 + KAFKA單機效能測試 文章來源：http://www.cnphp6.com/archives/51272 簡述storm叢集資料處理效能與kafka整合時效能瓶頸點及解決方式。 storm與kafka單機功能整合很順利，但是到了st
springboot kafka整合（包括java程式碼不能傳送和消費kafka訊息的採坑記錄）
kafka採坑記錄： 1、kafka服務端server.properties中的broker.id叢集內需要唯一。 2、kafka config檔案中listeners和advertised.listeners需要配置本機ip:9092
Java架構-spring+springmvc+kafka分散式訊息中介軟體整合方案
Honghu的訊息服務平臺已經拋棄了之前的ActiveMQ，改用高吞吐量比較大的Kafka分散式訊息中介軟體方案： kafka訊息平臺使用spring+kafka的整合方案，詳情如下： 使用最高版本2.1.0.RELEASE整合jar包：spring-integration
Kafka學習筆記（5）----Kafka使用Producer傳送訊息
1. Kafka的Producer 不論將kafka作為什麼樣的用途，都少不了的向Broker傳送資料或接受資料，Producer就是用於向Kafka傳送資料。如下： 2. 新增依賴 pom.xml檔案如下： <!-- https://mvnrepository.com/