카프카 프로듀서 보내기 문자열이 작동하지 않습니다.

Question

"이 프로그램이 실행 중입니다"라는 문자열을 카프카 항목으로 보내는 카프카 제작자를 만들려고합니다. 나는 왜 그것이 효과가 없는지 확신하지 못한다. 아래 코드는 다음과 같습니다. 나는 Cloudera 분포가 아니다.

package kafka_test; 

import java.util.Properties; 

import org.apache.kafka.clients.producer.KafkaProducer; 
import org.apache.kafka.clients.producer.ProducerConfig; 
import org.apache.kafka.clients.producer.ProducerRecord; 
import org.apache.kafka.common.serialization.StringSerializer; 

public class DataMovement { 

    public static void main(String[] args) { 

     String kafkaTopic = args[0]; 

     Properties props = new Properties(); 
     props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "server:9092"); 
     props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName()); 
     props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName()); 

     KafkaProducer<String, String> producer = new KafkaProducer<String, String>(props); 
     ProducerRecord<String, String> producerRecord = new ProducerRecord<String, String>(kafkaTopic, null, "This program is running."); 

     producer.send(producerRecord); 
     producer.close(); 

    } 
} 

나는 오류 메시지가 있지만 시간 제한하지 않습니다

또한 client.id 등 카프카, SSL, passowrd에 대한 정보를 많이 출력을

10분의 16/31 10:25:46 정보 utils.AppInfoParser : 카프카 버전 : 0.9.0.1 16/10/31 10:25:46 정보 utils.AppInfoParser : Kafka commitId : commitid 16/10/31 10:26:46 정보 생산자 .KafkaProducer : timeoutMillis = 9223372036854775807 ms 인 Kafka 제작자를 닫습니다.

Answer 1

코드가 정상적으로 작동합니다. 문제는 서버였습니다 : 9092는 Kafka 클러스터의 지정된 중개인의 주소 여야합니다 (활성 브로커를 대상으로했기 때문에 다릅니다).