kafka-producer-api

1열

1답변

나는 xml을 처리하고 있는데 카프카 프로듀서를 닫을 때 마지막 레코드를받을 때 레코드 당 메시지를 보낼 필요가있다. 카프카 프로듀서는 비동기식입니다. 따라서 프로듀서를 닫을 때 종종 java.lang.IllegalStateException: Cannot send after the producer is closed.이 나옵니다. 나는 프로듀서를 열어 둘 수

2열

1답변

동일한 주제에 대해 서로 다른 서버에 여러 제작자를 작성하는 것이 허용됩니까?

두 개의 서로 다른 서버에서 실행되는 두 개의 서로 다른 Producer 응용 프로그램이 있습니다. 두 제작자가 동일한 카프카 (Kafka) 주제에 글을 쓰게하는 것이 좋은 생각입니까? 모든 성능 문제가 예상됩니까?

2열

2답변

kafka-sink에서 여러 주제로 메시지를 라우팅하는 방법

http-outbound-gateway에 http-output-channel이있는 spring-xd http-processor 모듈이 있습니다. HTTP 200이 포함 된 메시지는 outputChannel에 제공되고 나머지는 failureChannel에 저장됩니다. 현재 http 프로세서 모듈은 TopicX가있는 kafka- 아웃 바운드 어댑터가있는 Kaf

1열

2답변

특정 카프카 제작자 또는 주제에 client-id를 할당하는 방법은 무엇입니까?

나는 는 기본적으로 나는 할당량 제대로 내 질문 할 수있는 방법입니다 작동 여부를 테스트하기 위해 특정 클라이언트 ID와 카프카 제작자 퍼포 레이션 테스트를 실행하려면 할당량이 클라이언트 ID를 기반으로하는 것을 알고 특정 제작자 (또는) 파티션에 대한 클라이언트 ID를 할당합니까?

4열

1답변

카프카 의원 선거는 언제 실시됩니까?

카프카 하이 레벨 프로듀서가 언제 그리고 얼마나 자주 리더를 선출합니까? 각 메시지를 보내기 전에 또는 연결을 만들 때 한 번만 수행합니까?

0열

1답변

큰 메시지와 함께 작동하도록 Apache Kafka의 .NET 제작자 클라이언트를 구성하는 중 오류가 발생했습니다.

.NET client (producer and consumer) of Apache Kafka을 사용하고 있습니다. 보낼 수있는 최대 메시지 크기를 늘리려고합니다. 나는 내 문제에 관한 configuration manual 일부 게시물을 읽어 : 나는 생산자에 대한 속성 "max.request.size"로 설정해야한다고 보았다 Kafka: Sending a

1열

1답변

카프카 프로듀서에서 RecordTooLargeException을 해결하는 방법?

FlinkKafkaProducer08을 사용하여 카프카에 기록을 보내고 있습니다. 하지만 언젠가는 오류 메시지에 인쇄하고있는 레코드의 크기가 0.02 MB로 너무 작아도 언젠가 예외를 따르고 있습니다. java.lang.RuntimeException: Could not forward element to next operator Caused by: java

3열

1답변

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

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

1열

1답변

스크립트를 사용할 때 Kafka에 데이터를 생성 할 수는 없지만 스크립트로 주제를 나열 할 수 있습니다.

모두 로컬 영역 네트워크에 가상 서버가 있으며 ip는 192.168.18.230이고 내 컴퓨터 IP는 192.168.0.175입니다. 오늘, 나는 카프카 콘솔 프로듀서 $ bin/kafka-console-producer.sh --broker-list 192.168.18.230:9092 --topic test 으로, 내 가상 서버 (192.168.18.2

0열

1답변

KafkaProducer onCompletion() 콜백은 항상 같은 스레드에서 실행됩니까?

카프카 API 0.10.1 : Link onCompletion 콜백이 동일한 스레드에서 순차적으로 호출된다는 보장이 있습니까? 설명서에는 "콜백은 일반적으로 제작자의 I/O 스레드에서 실행된다는 점에 유의하십시오. 그래서 나는 아니오라고 생각할 것입니다. 예를 들어, 정수 카운터를 유지하여 발생한 예외 수를 추적하려면 AtomicInteger를 사용해야합니