Shulou(Shulou.com)06/01 Report--

Kafka production failure to send messages or Error while fetching metadata with correlation id how to do, many novices are not very clear about this, in order to help you solve this problem, the following editor will explain in detail for you, people with this need can come to learn, I hope you can gain something.

Today, when I was using code to write kafka producers to send messages, something funny happened because of my hand mistake.

The same code and kafka were executed not long ago, and there is no problem. The code is as follows

Package streaming.utilsimport java.utilimport java.util. {Date, Properties, UUID} import com.alibaba.fastjson.JSONObjectimport org.apache.commons.lang3.time.FastDateFormatimport org.apache.kafka.clients.producer. {KafkaProducer, ProducerRecord} import scala.util.Random/** * Author: Michael Competition QQ: 1990218038 * * Kafka data producer * / object ProducerApp {def main (args: Array [String]): Unit = {val props = new Properties props.put ("key.serializer") "org.apache.kafka.common.serialization.StringSerializer") props.put ("value.serializer", "org.apache.kafka.common.serialization.StringSerializer") props.put ("bootstrap.servers", ParamsConf.brokers) props.put ("request.required.acks", "1") val topic = ParamsConf.topic val producer = new KafkaProducer [String,String] (props) val random = new Random () val dateFormat = FastDateFormat.getInstance ("yyyyMMddHHmmss") for

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.