apache-kafka

1열

1답변

버전 카프카 오프셋 커밋 스파크 2.2 카프카 0.11 카프카의 오프셋을 저지 documentation에 따른 I가 사용해야 stream.asInstanceOf[CanCommitOffsets].commitAsync(offsetRanges) 결과 오프셋은 sta에서만 커밋됩니다. 다음 배치의 rt. 그것은 '일정한'지체를 야기합니다. 현재 배치가 끝날 때 오

0열

1답변

HDInsight (Azure)에 설치된 Kafka에 연결

Azure에서 HDinsight의 일부로 시작한 Kafka 클러스터에 외부 Java 응용 프로그램을 연결해야합니다. 브로커 3 인스턴스, ZooKeepers 3 개, ZooKeeper 클라이언트 1 개가있는 클러스터가 있습니다. 이제 내 질문 : 브로커 연결 문자열을 지정하는 방법. 관리자 패널에서 나는 브로커 (xxx-1.yyy.zzz.internal.c

0열

1답변

Spring Cloud Stream 카프카 바인더 : "IN_TRANSACTION 상태에서 IN_TRANSACTION 상태로의 변환이 잘못되었습니다."

Spring Cloud Streams + Kafka Binding을 사용하여 Apache Kafka에서 "정확히 하나의 전달"개념으로 PoC를 수행하려고합니다. Apache Kafka "kafka_2.11-1.0.0"을 설치하고 제작자에 "transactionIdPrefix"를 정의했습니다. 봄 카프카에서 트랜잭션을 사용하려면이 작업을 수행해야합니다.하지만

0열

1답변

Kafka Streams : 동일한 'application.id'를 사용하여 여러 주제에서 사용하십시오.

여러 개의 다른 주제를들을 필요가있는 애플리케이션이 있습니다. 각 주제에는 메시지 처리 방법에 대한 별도의 논리가 있습니다. 각 KafkaStreams 인스턴스에 대해 동일한 카프카 속성을 사용하려고 생각했지만 아래 오류가 발생합니다. 오류 java.lang.IllegalArgumentException: Assigned partition my-topic-1

2열

1답변

KSQL 테이블의 데이터 읽기

어쩌면 이것은 초보자 용 질문 일 수도 있지만 KSQL에서 생성 된 데이터를 읽는 데 권장되는 방법은 무엇입니까? 일부 스트림 처리를 수행하고 데이터를 KSQL 테이블에 기록한다고 가정 해 보겠습니다. 이제 스프링 애플리케이션을 통해이 데이터에 액세스하려고합니다 (예 : 웹 소켓을 통해 일부 실시간 데이터 팬 아웃). 내 첫 번째 추측은 Spring Kaf

0열

1답변

카프카 토픽이 올바르게 설정되었는지 테스트하기

우리 애플리케이션은 다양한 유형의 큐를 사용합니다. 대기열을 사용하는 응용 프로그램을 시작하기 전에는 필요한 대기열에 샘플 메시지를 쓰고 대기열이 올바르게 설정되어 있는지 확인하기 위해 해당 대기열을 읽는 (즉, 삭제하는) 자동화 된 사전 점검이 있습니다. 이제는 카프카도 사용합니다. 그러나 카프카에서는 주제를 "오염시키는"일종의 실제 응용 프로그램을 시작

0열

2답변

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

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

0열

1답변

Vagrant의 Kafka 클러스터 (ZK, BR, BR, BR)가 연결을 설정할 수 없습니다.

문제는 제작자 스크립트를 통해 클러스터의 모든 브로커에 메시지를 보낼 수 없다는 것입니다. 설치 프로그램은 ip (192.168.10.2:2181)에서 기본 설정으로 실행되는 단일 사육사 서버입니다. 또한, (192.168.10.101:9092,192.168.10.102:9092,192.168.10.103:9092)에서 실행중인 3 개의 브로커가 있습니다.

0열

1답변

log4j2.xml의 kafka appender가 작동하지 않습니다.

문제를 해결하는 데 도움을주십시오 .Thx! :) log4j2를 사용하여 tomcat에서 로그를 출력하고 싶다면이 로그를 kafka에 출력 할 수 있습니다. 내 log4j2.xml 바람둥이에/lib 디렉토리는 다음과 같습니다 나는 바람둥이를 실행하면 로그 log4j에 변경되지 않습니다 <?xml version="1.0" encoding="UTF-8"?>

0열

1답변

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

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