오류 : "문자열"

Question

코드는

props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, 
        io.confluent.kafka.serializers.KafkaAvroSerializer.class); 
      props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, 
        io.confluent.kafka.serializers.KafkaAvroSerializer.class); 
      props.put("schema.registry.url", "http://localhost:8081"); 
      producer = new KafkaProducer<>(props); 

    public void send(List<String> results){ 
      TestCallback callback = new TestCallback(); 
      for (Object result : results) { 
       ProducerRecord<String, String> record = new ProducerRecord(topic,result.toString());<==confused at this point 
       producer.send(record,callback); 

      } 
      producer.close(); 
     } 

전송 방법은 SQL 쿼리에서 가져온 기록의 목록이 들어있는 카프카 주제에 브로 메시지를 보낼 수 있습니다. 하루의 끝에서

2017-10-05 23:54:36 DEBUG RestService:118 - Sending POST with input {"schema":"\"string\""} to http://localhost:8081/subjects/my_topicq1-value/versions 
Exception in thread "main" org.apache.kafka.common.errors.SerializationException: Error registering Avro schema: "string" 

오류, 나는 주제에서와 HDFS에 넣어 카프카 - 연결 - HDFS를 사용하여 이러한 레코드를 가져 싶었다.

진행할 수 있도록 입력 해주세요. 감사합니다.!

Answer 1

SQL 레코드를 가져 오는 경우 맞춤 제작자가 필요합니까? Kafka Connect JDBC Connector을 사용하여 SQL 쿼리에서 직접 데이터를 가져온 다음 Kafka Connect를 HDFS로 가져 오시겠습니까?