kafka-consumer-api

0열

1답변

Python - Kafka : consumer failing

나는 프로듀서 - 소비자 설정이 간단합니다. 제작자 1 명 (스레드)과 소비자 2 명 (2 개 프로세스)이 있습니다. 생산자의 실행 방법 : def run(self): producer = KafkaProducer(bootstrap_servers=self.bootstrap_servers, api_version=(0, 10))

python kafka-consumer-api kafka-producer-api 2017-12-17

---

1열

2답변

kafka에서 읽기 및 kafka로 kafka로 읽는 성능을 향상시키는 방법 Stream Application

카프카 스트림 응용 프로그램에 1.0.0 카프카 스트림 API가 있습니다. 단일 브로커 0.10.2.0 kafka 및 단일 파티션의 단일 주제가 있습니다. 구성 가능한 모든 매개 변수는 제작자 request.timeout.ms를 제외하고 동일합니다. Kafka Streams program is throwing exceptions when producing

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-streams 2017-12-19

---

0열

1답변

Kafka gzip 압축 메시지를 주제에서 Spark Streaming으로 읽는 방법

Gzip 압축을 사용하려면 제작자 측에서 변경해야하지만 메시지를 읽는 동안 압축 해제하는 방법을 모르겠습니다. 통해 밖으로 시작하십시오. 시작하는 방법에 대한 약간의 조명. 압축되지 않은 메시지에 대해 My End to End Streaming이 작동합니다. 고마워요.

apache-spark apache-kafka spark-streaming kafka-consumer-api 2017-12-19

---

0열

1답변

브로커 기반 오프셋을 사용하여 프로그래밍 방식으로 소비자 지연 가져 오기

저는 하루 종일 인터넷을 통해 빗질 해 왔으며 제대로 작동하지 못했습니다. 내가 원하는 것은 주어진 groupID에 대한 소비자 그룹 래그 메트릭 (또는 현재와 마지막에서 파생 된 2 개의 오프셋)입니다. 메신저 kafka 0.9+ (그래서 사육사의 오프셋 없음)를 사용하고 필요하면 더 새로운 것을 사용할 수도 있습니다. 스크립트를 사용하지 않고 프로그래밍

apache-kafka kafka-consumer-api metrics 2017-12-19

---

0열

1답변

카프카 HA 소비자 설치

내 응용 프로그램은 내가 단일 인스턴스 내 환경에서 실행하지만 여러 인스턴스를 실행할 경우 말할 수있을 때 잘 작동 카프카 주제에서 메시지를 소비 3 인스턴스 (고 가용성)의 인스턴스의 다음 아무 것도 없음 주제로부터 메시지를 소비 할 수있는 애플리케이션. 은 그 주제에 3 파티션 1 개 복제 요인이있다. 내가 ./kafka-topics.sh --descr

apache-kafka kafka-consumer-api 2017-12-20

---

0열

1답변

log.debug (그룹 {}에 대해 코디네이터를 검색하지 못했습니다. 메타 데이터를 새로 고침 ", groupId) kafka 0.11.0.x로

저는 Kafka (버전 0.11.0.2) 서버 API를 사용하여 로컬 호스트에서 kafka 브로커를 시작합니다. 어떤 문제없이 실행됩니다. 또한, 제작자는 메시지 성공을 보낼 수 있습니다. 그러나 소비자는 메시지를받을 수 없으며 콘솔에 오류 로그가 없습니다. 코드를 디버깅 한 후 "refreshing metadata"에 대해 반복합니다. 여기 소스 코드를

apache-kafka kafka-consumer-api 2017-12-20

---

0열

2답변

org.apache.kafka.common.KafkaException : kafka 소비자를 생성하지 못했습니다.

수동으로 Zookeeper를 시작한 다음 Kafka 서버를 시작하고 마지막으로 Kafka-Rest 서버를 해당 속성 파일로 시작합니다. 다음으로는 톰캣 로그 추적에서 바람둥이 내 봄 부팅 응용 프로그램을 배포하고, 나는 오류 org.springframework.context.ApplicationContextException: Failed to start b

spring-boot apache-kafka kafka-consumer-api spring-kafka 2017-12-25

---

0열

1답변

카프카 (Kafka) 두 개의 다른 체크 포인트가있는 한 명의 소비자

카프카 (Kafka)의 특정 주제에서 데이터를 소비하는 카프카 소비자 프로젝트가 있습니다. 레코드의 90 %는 처리 되 자마자 처리되지만 일부 레코드 (10 %)를 처리하는 지연이 있습니다. 이러한 기록을 지연시켜야 기록을 커밋 할 수 없으므로 Kafka가 새 노드에 파티션을 재 할당 할 수 있습니다. 이를 방지하기 위해 동일한 주제를 두 번 읽고 두 번째

apache-kafka apache-zookeeper kafka-consumer-api apache-kafka-connect 2017-12-26

---

0열

2답변

단일 파티션이있는 항목에 대해 동일한 group.id를 가진 여러 소비자의 예상 동작

특정 주제를 수신하는 동일한 group.id를 가진 여러 소비자가 모두 있습니다. 주제에는 하나의 파티션이 있습니다. 동일한 소비자 그룹의 소비자 (동일한 group.id로 식별 됨)는 단일 소비자 만 메시지를 처리 ​​할 수 ​​있도록 라운드 로빈 방식으로 메시지를 받게된다는 것을 알고 있습니다. 소비자가 서로 다른 컴퓨터에서 서로 다른 Windows 서

c# apache-kafka kafka-consumer-api 2017-12-28

---

0열

1답변

org.springframework.kafka.listener.ListenerExecutionFailedException : 리스너 메소드가 java.lang.NullPointerException을 던졌습니다.

리스너 메소드의 내 고객 클래스 InventoryEventReceiver에서 아래 오류가 발생합니다. NullPointerException이 표시되는 이유를 모르십니까? 나는 단지 두 개의 InventoryEvent 개체를 게시하고 있습니다. 빠른 도움말을 보내 주시면 감사하겠습니다. 리스너 방법 public class InventoryEventReceiv

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect spring-kafka 2017-12-29

---