kafka-consumer-api

2열

2답변

서버 (바람둥이)에 배치 된 나머지 기반 응용 프로그램을 가지고 있습니다 (바람둥이), 모든 요청은 서버에 제공되기까지 1 초가 걸립니다. 이제는 문제가 발생합니다. 요청하면 서버를 비 응답으로 만드는 서비스를 제공 할 수 있습니다. 이제 서버가 요청을 가져 와서 해당 요청을 처리하고 선택 시간 문제를 처리 할 수 있도록 요청을 큐에 저장할 수 있는지

0열

1답변

두 명의 카프카 소비자가 이상한 행동을 일으키고 있습니다.

다른 고객 ID와 그룹 ID를 가진 두 명의 소비자가 있습니다. 보존 시간과 최대 파티션 외에 Kafka 설치에는 기본 구성이 포함되어 있습니다. 나는 다른 누군가가 같은 문제를 가지고 있지만 어떤 결과를 끌어낼 수 있는지 살펴보기 위해 둘러 보았다. 그래서 시나리오는 다음과 같이 진행됩니다 소비자 A : 은, 카프카에 연결 소비 할 필요가 약 300 만

3열

1답변

kafka 소비자 반입 API가 올바른 오프셋 값을 반환하지 않습니다.

실험용 카프카 환경을 3 개의 브로커와 3 개의 파티션이있는 주제로 설정했습니다. 제작자와 소비자가 있습니다. 특정 소비자를위한 파티션의 오프셋을 수정하고 싶습니다. kafka 문서에서 소비자 커밋/페치 API 인 kafka가 특정 오프셋을 커밋하거나 소비자가 읽은 최신 오프셋을 가져올 수 있음을 읽었습니다. 나는 특정 소비자에서 오프셋을 가져 오기 위해

0열

1답변

kafka에서 생산자에서 소비자로 물체를 소비하는 방법은 무엇입니까?

다음은 제작자와 소비자를위한 클래스입니다. 언제 데이터를 생성 할 수 있으며 다음 코드로 데이터를 소비 할 수 없습니다. 한번도 나를 도울 수 있습니까? 코딩에 잘못이 있었습니까? 제 목표는 소비자로부터 CustomMessage 개체를 읽고 DB에 데이터를 저장하는 것입니다. 내 cmd 프롬프트에서 zookeeper 용 인스턴스 1, kafka 용 1, 생

0열

2답변

카프카 (Kafka)에 대한 상위 수준 소비자 API주기 0.8

상위 수준 소비자의 라이프 사이클에 대한 설명을 찾을 수 없습니다. 저는 0.8.2.2에 있으며 카프카 - 클라이언트의 "현대"소비자는 사용할 수 없습니다. 여기 내 코드는 다음과 같습니다. def consume(numberOfEvents: Int, await: Duration = 100.millis): List[MessageEnvelope] = {

0열

1답변

Kafka 0.10.2 많은 수의 소비자가 중복 됨

동일한 그룹 ID를 가진 모든 생산자, 1 개의 주제, 10 개의 파티션, 10 개의 파티션, 10 개의 KafkaConsumers가 하나의 컴퓨터에서 실행됩니다. 파일을 처리 할 때 제작자는 소비자가 행복하게 소비하기 시작하는 3269 개의 메시지를 신속하게 작성합니다. 모든 것이 잠시 동안 잘 돌아가지만 특정 시점에 소비자는 중복을 소비하기 시작합니

0열

1답변

Kafka가 역순으로 메시지를 사용합니다.

카프카 0.10을 사용합니다. 내 IoT 장치가 로그를 게시하는 logs이라는 주제가 있습니다. 내 메시지의 키는 device-id이므로 동일한 장치의 모든 로그는 동일한 파티션에 있습니다. . 나는 API가 /devices/{id}/tail-logs인데 전화가 걸린 순간에 한 장치의 N 개의 마지막 로그를 표시해야합니다. 현재 현재의 타임 스탬프에 도달

1열

1답변

카프카 스트리밍이 여러 인스턴스와 함께 작동하지 않습니다.

카프카 스트림 어플리케이션의 여러 인스턴스를 실행할 때 첫 번째 인스턴스 만 올바르게 메시지를 수신합니다. 그러나 새 인스턴스를 시작하면 메시지가 수신되지 않습니다. 이 문제를 해결하기위한 제안이 있으십니까? 여기 내가이 문제가있는 생각 내 카프카 스트리밍 응용 프로그램 package test.kafkastream; import java.util.Pro

4열

1답변

Consumer.poll()은 오프셋을 커밋하지 않고도 새 레코드를 반환합니다.

enable.auto.commit=false이 있는데 consumer.commitAsync()을 호출하지 않고 consumer.poll()을 호출하면 consumer.poll()은 다음에 호출 할 때 새 레코드 을 반환합니까? 오프셋을 커밋하지 않았으므로 poll()은 같은 레코드이어야하는 최신 오프셋을 반환합니다. 내가 처리하는 동안 실패 시나리오를 처리

2열

1답변

kafka에서 소비자 그룹을 재설정하는 방법은 무엇입니까?

확실하지 제목이 맞다면 ... 어쨌든 가정 I했습니다 다음 시나리오 (테스트를 실행할 때이 많이 발생) : 소비자가 하나의 파티션 및 그룹과 주제에 시작 ID 테스트 나는 close() 내가 같은 테스트를 다시 시작 사용하지 않고 소비자를 죽일. 는 소비자는 일부 로그 출력에 시작 : 2017-04-20 12:01:46 DEBUG NetworkClient: