kafka-producer-api

0열

1답변

Kafka Connector - Kafka 용 JMSSourceConnector 토픽

기본적으로 Confluent는 Kafka 주제에 대해이 JMSSourceConnector를 제공합니다. 아니면이 용도로 맞춤 커넥터를 작성해야합니까? 이 문서의 Confluent 페이지에 관련 문서가 없습니다.

jms kafka-producer-api confluent apache-kafka-connect 2016-09-24

---

2열

1답변

카프카 소비자가 특정 키 메시지를들을 수 있습니까?

저는 카프카가 처음입니다. 특정 메시지 만 읽어야하는 요구 사항이 있습니다. 이를 위해 나는 키와 값으로 카프카에게 메시지를 보낼 것이다. 특정 키 목록에 소비자를 등록 할 수있는 방법이 있습니까? 그래서 메시지가 Kafka에 푸시 될 때, 소비자는 메시지가 소비자가 듣고있는 키를 가지고 있다면 소비 할 것입니다.

apache-kafka kafka-consumer-api kafka-producer-api 2016-09-29

---

0열

1답변

logstash를 사용하여 kafka에 로그 파일을 쓰는 방법은 무엇입니까?

logstash를 사용하여 kafka 주제에 로그 파일을 보내려고합니다. kafka에 출력을 보내려면 logstash 구성 파일에 어떤 구성이 필요한지 잘 모릅니다. 비슷한 일을 한 사람이 있으면 친절하게 공유하십시오. output { kafka { topic_id => "your_topic_id" } } Here이 문서는

logstash-configuration kafka-producer-api 2016-09-29

---

1열

1답변

InfluxDB에서 Kafka로 데이터를 보내는 방법이 있습니까?

유입 데이터를 kafka로 보내는 방법이 있습니까? 또한 카프카 주제에는 정의 된 avro 스키마가 있습니다. 그래서 이것을 염두에두고 InfluxDB에서 kafka로 데이터를 보내는 방법이 있는지 알고 싶었습니다.

apache-kafka avro influxdb kafka-producer-api 2016-09-29

---

0열

3답변

java.lang.NoClassDefFoundError : org/apache/kafka/common/message/KafkaLZ4BlockOutputStream

Spark 스트리밍 API를 사용하는 동안 NoClassDefFoundErrorerror가 표시됩니다. 여기에 내 스트리밍 코드가 있습니다. 나는 이것이 어떤 짝수 항아리와 의존성에 문제가 있다는 것을 알고 있지만 정확히 무엇인지 알아 내지 못했습니다. kafka 0.9.0, spark 1.6.1을 사용하고 있습니다. 이러한 의존성이 양호합니까 아니면 변경

apache-spark apache-kafka spark-streaming kafka-producer-api 2016-10-07

---

0열

1답변

카프카 주제에 XML 데이터를 보내는 가장 좋은 방법은 무엇입니까?

을 Java API를 사용하여 Kafka topic으로 보내려고합니다. 왜냐하면 0.9.0 version에서 더 나은 성능을 얻기 위해 Java API 대신 Scala API를 사용하기를 제안하기 때문입니다. http://kafka.apache.org/090/documentation.html#producerapi 내 XML 파일 주위 5 MB data 가지

java xml apache-kafka kafka-producer-api 2016-10-08

---

0열

2답변

Kafka 상위 수준 ConsumerConnector를 사용할 때 어디에서 오프셋을 유지해야합니까?

새로운 문서에서 알 수 있듯이 Kafka는 기본적으로 고급 API를 사용할 때 오프셋 관리를 담당합니다. 하지만 아래와 같이 ConsumerConnector를 만들면 여전히 zookeeper.connect 속성을 제공해야합니다. _consumerConnector = Consumer.createJavaConsumerConnector(consumerConfig

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect 2016-10-12

---

1열

1답변

카프카 프로듀서 RecordTooLargeException

나는 다음과 같은 오류를 얻고있다 org.apache.kafka.common.errors.RecordTooLargeException : 직렬화 할 때 메시지는 당신이 함께 구성한 총 메모리 버퍼보다 ​​큰 인 196,773 바이트 buffer.memory 구성 " 하지만 내 생산자 설정에서 buffer.memory는 10,485,760 확실하지 왜? 감사

apache-kafka kafka-producer-api 2016-10-13

---

0열

1답변

최고의 카프카 프로듀서

나는 여러 생산자는 우리가 있다는 것을 발견? 어떤 것을 사용해야하고 왜 사용해야합니까? 제안하십시오!

apache-kafka kafka-producer-api 2016-10-13

---

0열

1답변

소비자 그룹 ID가 포함 된 KafkaSpout 만들기

한동안 주제를 구독하는 kafkaspouts 그룹을 만드는 방법에 대해 많은 시간을 보냈습니다. spoutconfig에있는 id를 인용하는 일부 소스가 그룹 id로 사용될 수 있음을 발견했습니다. 나의 주된 문제는 spouts가 그룹으로 작용 하는지를 어떻게 알 수 있는가이다. 나는 또한 setSpout()의 paralellism_hint가 paralell

apache-kafka apache-storm kafka-consumer-api kafka-producer-api 2016-10-17

---