producer

0열

1답변

kafka 0.10 콘솔 제작자가 kafka 0.9에 메시지를 보낼 수없는 이유는 무엇입니까?

kafka 0.10 콘솔 제작자가 kafka 0.9에 메시지를 보낼 수없는 이유는 무엇입니까? 저는 (서버 측에서) 버전 0.9에서 kafka 콘솔 소비자를 시작할 것입니다. (클라이언트 측에서) 버전 0.10에서 kafka 콘솔 제작자를 시작하려고합니다. 그렇다면 생산자 예외가 발생했습니다 (아래). 어떻게 새로운 생산자가 구 소비자에게 메시지를 보낼 수

java apache-kafka versions consumer producer 2016-08-30

---

0열

1답변

Fink : KafkaProducer 데이터 손실

Flink 스트리밍 워크 플로는 Kafka에 메시지를 게시합니다. KafkaProducer의 '재시도'메커니즘은 메시지가 내부 버퍼에 추가 될 때까지 시작되지 않습니다. 그 전에 예외가 발생하면 KafkaProducer가 해당 예외를 throw하고 Flink에서 처리하지 않는 것처럼 보입니다. 이 경우 데이터가 손실됩니다. 관련 FLINK 코드 (Flink

apache-kafka apache-flink producer 2017-02-02

---

0열

1답변

socket.error로 인해 Kafka Producer를 실행할 수 없습니다. [Errno 48] 주소가 이미 사용 중입니다.

로컬 도커 - 기계가 있는데 파이썬으로 작성된 Kafka 제작자를 실행하려고합니다. 그러나, 그것은 socket.error를 제공합니다 : [Errno 48] 주소는 이미 사용 중이며 중지되었습니다. 어떤 도움을 주셔서 감사합니다! 오류 메시지 : 도커 기계 고정 표시기 기계에 이미지 컨테이너 명령 생산자를 실행하는 $ python producer.py

apache-kafka producer 2017-11-29

---

0열

1답변

kafka-avro-console-producer를 사용하는 방법?

'kafka-console-producer'를 사용하면 JASS 파일이 자동으로 선택되어 정상적으로 실행됩니다 (원격 주제로 생성 될 수 있음). 내가 사용하는 경우 '카프카 - 브로 콘솔 프로듀서'동일한 구성으로하지만, 추가 스키마 속성 -이 JASS 구성에 대해 불평 : 'Could not find a 'KafkaClient' entry in the J

properties apache-kafka producer-consumer producer 2017-10-12

---

0열

1답변

ProducerInterceptor 추가 - Kafka

메시지를 직렬화하기 전에 차단하려고합니다. ProducerInterceptor라는 인터페이스가 이미 있으므로 레코드를 수정하는 데 사용할 수 있습니다. 해당 인터페이스를 구현하고 데이터를 수정 한 클래스를 만든 후에는 새 클래스를 넣어야 할 필요가있는 일부 파일을 수정해야합니까?

apache-kafka interceptor producer 2017-05-18

---

0열

1답변

iTunes 프로듀서의 java.net.MalformedUrlException

iTunes 제작자에 ePub를 게시하려고합니다. ePub 파일은 epubcheck 도구에서 유효성 검사를 통과합니다. EPUB를 제출하면서 나는 다음과 같은 오류가 발생하고있다 : Error: Internal error: java.net.MalformedURLException: unknown protocol: bundle schema/20/rng/cont

ios itunesconnect itunes itunes-store producer 2017-12-07

---

0열

1답변

프록시를 사용하여 CDI 프로듀서를 삽입하십시오.

이전 게시 된 질문에서 발견 한 몇 가지 제안을 따르려고했지만 완전한 해결책을 얻지 못하는 것 같습니다. 다음 코드를 사용 : @Produces @Dependent @RestClientResourceConnector public <T> RestClientProxy<T> getStatusResource(InjectionPoint injectionPoin

generics java-ee cdi weld producer 2016-09-30

---

4열

1답변

메시지를 생성 할 때 주제를 찾을 수 없습니다. UNKNOWN_TOPIC_OR_PARTITION

각 노드가 별도의 브로커로 사용되는 2 노드 카프카 클러스터 (EC2 인스턴스)가 있습니다. 나는 다음과 같은 명령을 사용하여 리더 인스턴스의 프로듀서를 실행하면 : kafka-console-producer.sh --broker-list localhost:9092 --topic test 을 나는 다음과 같은 오류를 얻을. test message [201

apache-kafka consumer producer 2017-01-09

---

1열

1답변

파이프 소비자/생산자 : 포크 후 아버지/아들이라는 측면에서 소비자/생산자가되어야합니다.

우선 불량 영어가 사용되면 죄송합니다. 내 메모에 나는 그 자식 프로세스가 대개 제작자이지만 그 이유를 모르겠다는 것을 썼습니다. fork() 호출 후 소비자와 제작자는 누가 중요한가 ?? 문제는 자식 프로세스가 제작자 인 경우 아버지가 수행하기 전에 끝내기 때문에 자식 프로세스가 좀비 프로세스가된다는 의미입니다. 내가 이해하려고 노력 중이 야이 질문에 대

pipe fork consumer producer 2017-12-27

---

0열

1답변

tensorflow.train.string_producer returns nothing

나는 cifar-10 cnn 모델을 사용하여 내 자신의 이미지 데이터를 훈련 시키려고합니다. 디버그 정보는 아래에 있습니다. 디버그 위치는 다음과 같습니다 # Create a queue that produces the filenames to read. filename_queue = tf.train.string_input_producer(file

string input tensorflow producer 2016-08-30

---