kafka-consumer-api

0열

1답변

생산자와 소비자가 Kafka 클러스터에 얼마나 많은 연결을 했습니까?

Java 클라이언트에서 생산 및 소비하는 동안 연결 수와 생성자 및 소비자가 Kafka 클러스터에 연결하는 유형을 밝힐 수 있습니까? 클러스터의 항목 또는 파티션 또는 브로커를 기반으로하는 연결 수입니까?

apache-kafka kafka-consumer-api kafka-producer-api 2017-09-19

---

1열

1답변

자동 커밋을 할 수있는 동안 수동으로 파티션을 할당하는 방법은 무엇입니까?

소비자 그룹 내의 각 소비자에게 파티션을 수동으로 할당하려고합니다. 그룹에 소비자를 추가하는 것처럼 보이지만 Kafka (또는 적어도 kafka-python)는 그룹 코디네이터가 모든 과제를 수행하기를 원한다고 가정합니다. 파티션 할당을 수동으로 관리 할 수있는 동안 소비자 그룹 (특히 자동 커밋) 사용의 모든 이점을 계속 유지할 수있는 방법이 있습니까?

apache-kafka kafka-consumer-api kafka-python 2017-09-20

---

0열

1답변

수동 커밋을 위해 Spring Kafka의 Acknowledgement.acknowledge() 메소드를 사용하는 방법

스프링 카프카를 처음 사용하고 있으며 여기에서 언급 한 것처럼 내 소비자 코드에서 Acknowledgement.acknowledge() 메소드를 수동 커밋에 사용할 수 없습니다. https://docs.spring.io/spring-kafka/reference/html/_reference.html#committing-offsets. 내 것은 스프링 부트 응

java spring-boot kafka-consumer-api spring-kafka 2017-09-20

---

0열

1답변

wurstmeister 카프카의 LEADER_NOT_AVAILABLE 오류

아래 링크를 사용하여 카프카 클러스터를 설정하려고합니다. https://github.com/wurstmeister/kafka-docker 나는 약간의 MSG를 생산하려고 할 때 나는이 다음 오류가 발생합니다. [2017-09-20 17:00:53,160] WARN Error while fetching metadata with correlation id 3

apache-kafka kafka-consumer-api kafka-producer-api 2017-09-20

---

0열

1답변

Kafka 다중 소비자에서 한번만 메시지를 보내는 메시지

카프카 메시징은 모든 메시지가 처리되도록하기 위해 최소 한 번만 메시지를 전달하며 다음 메시지를 전달할 메시지 오프셋을 사용합니다. 여러 소비자가있는 경우 치명적인 메시지가 메시지 처리 중에 소비자 충돌을 일으키는 경우이 메시지가 다른 소비자에게 재전송되고 사망자가 확산됩니까? 메시지가 단일 사용자를 차단하면 다른 고객이 계속 메시지를 처리하고 후속 메시지

apache-kafka message-queue kafka-consumer-api 2017-09-22

---

0열

1답변

Kafka 소비자 오프셋 완료 가능 future 내에서

나는 생성자의 일부로 스레드 내부에서 생성 된 실행 메소드 내 스레드 내에서 Kafka 소비자 인스턴스를 만들었으며 다른 웹 서비스를 호출하고 호출을 비 차단으로 유지할 수 있도록 completable future를 사용하고 있습니다. 내 문제는 나에게 thenAppApply 메서드를 호출하고 Kafka 소비자가 스레드 안전하지 않다는 오류를 주므로 Kaf

java multithreading java-8 apache-kafka kafka-consumer-api 2017-09-22

---

0열

2답변

카프카 리스너에게 주제를 동적으로 전달하는 방법은 무엇입니까?

며칠 동안 Java DSL에서 키를 사용하여 주제를 카프카 리스너에 동적으로 전달하는 방법을 시도하고 있습니다. 주변에있는 사람이라면 누구든지이 일을 수행하기위한 가장 좋은 방법은 무엇인지에 관해 밝힐 수 있습니까?

java apache-kafka kafka-consumer-api 2017-09-25

---

0열

1답변

Apache Kafka 프로듀서 소비자 API 문제

카프카 프로듀서 및 소비자를 테스트하기위한 간단한 Java API를 만들려고합니다. Mac 컴퓨터의 별도 터미널에서 생산자와 소비자를 실행할 때 작동합니다. 하지만이 오류, 자바 API 코드를 사용하여 점점 카프카 서버에 연결을 시도 : 스레드에서 예외를 kafkatest2.ProducerTest.main에서 java.lang.NullPointerExcep

apache-kafka kafka-consumer-api kafka-producer-api 2017-09-25

---

0열

2답변

파이썬 KafkaConsumer가 타임 스탬프에서 메시지를 소비하기 시작합니다.

주제의 시작을 건너 뛰고 특정 타임 스탬프의 메시지 만 끝까지 읽으려고합니다. 이것을 달성하는 방법에 대한 힌트가 있습니까?

python-3.x apache-kafka kafka-consumer-api kafka-python 2017-09-25

---

1열

1답변

스프링 카프카 소비자 - 동시 청취자와 클라우드의 비 동시 청취자

저는 스프링 카프카를 사용하여 카프카 소비자를 만들고 클라우드 파운드리에 배포했습니다. 주제에는 10 개의 파티션이 있습니다. 각 인스턴스가 하나의 파티션에서 메시지를 소비 할 수 있도록 앱을 10 인스턴스로 확장 할 계획입니다. 스프링 카프카 (Spring Kafka)는 동시 메시지 수신기 컨테이너를 지원합니다. 각 파티션에서 소모하는 스레드를 두 개 이

apache-kafka cloudfoundry kafka-consumer-api pivotal-cloud-foundry spring-kafka 2017-09-26

---