kafka-producer-api

1열

1답변

3 개 노드 카프카 클러스터를 설정했습니다. 나는 프로듀서 클라이언트에서 사용할 수있는 중개인이 누구인지 알고 싶습니다. 사육사와 연결된 중개인을 나열하는 명령이 있습니까?

2열

1답변

자바 API를 통해 카프카 토픽에 대한 일련의 작업을 수행하는 애플리케이션을 작성 중입니다. 주제를 만들고 파티션을 추가 할 수 있습니다. 주제 메타 데이터 (예 : 파티션, 브로커) 및 구성을 가져 와서 구성을 업데이트하는 데 도움이 필요합니다. 는 참고로, 나는 여기에 제공된 주제 레벨 구성을 업데이트 할 - https://kafka.apache.org

0열

1답변

Kafka 제작자가 메시지를 건너 뛰는 중

파일에서 카프카 항목으로 데이터를 쓰려고합니다. 내 코드는 다음과 같습니다. Properties properties = new Properties(); properties.put("bootstrap.servers", <bootstrapServers>); properties.put("key.serializer", StringSerialize

1열

1답변

카프카 소비자는 주제에서받은 모든 메시지를 알아야합니다.

카프카 소비자 부분의 스파크 스트리밍에서 소비 된 레코드를 정렬해야합니다. 카프카 소비자가 소비하는 모든 출판 기록을 아는 것이 가능합니까?

0열

1답변

카프카 생산자의 주제 구독자 수를 취득하는 옵션

카프카 프로듀서 [KafkaProducer]에서 특정 주제에 대한 가입자의 수를 찾는 옵션이 있습니까?

0열

2답변

카프카 제작자의 request.timeout.ms 및 timeout.ms 속성 간의 차이

kafka documentation을 참조하면 카프카 메시지 작성자 구성은 request.timeout.ms 및 timeout.ms 속성을 갖습니다. 이 두 속성에 대한 설명을 읽으면 나는 그것들을 명확히 구분할 수 없습니다. 누구든지 작은 예를 사용하여 차이점을 설명 할 수 있습니까?

1열

1답변

카프카에 성공적으로 쓰여지지 않은 메시지 수집

나는 카프카에서 파일을 읽고 각 레코드를 덤핑하고 있습니다. 내 프로듀서 코드는 다음과 같습니다. public void produce(String topicName, String filePath, String bootstrapServers, String encoding) { try (BufferedReader bf = getBufferedReade

0열

1답변

카프카가 클라이언트 자바에서 advertised.host.name을 오버라이드

우리는 kafka 0.8.2.1을 하나의 도커 컨테이너에서 실행합니다. 이것은 도커 작성과 함께 작동하도록 설정된 몇 가지 컨테이너 중 하나입니다. 도커 작성기는 kafka 9092 포트를 호스트 시스템에 노출합니다. 카프카 서버의 advertised.host.name은 kafka으로 설정되며 다른 모든 컨테이너는이 이름을 사용하여 문제없이 말할 수 있습니

2열

2답변

많은 파티션이있는 주제에 대해 메시지 순서가 어떻게 보존됩니까?

메시지가 여러 파티션으로 구성된 주제에 기록 될 때 카프카가 메시지 순서를 유지하는 방법에 대한 정보/설명이 필요합니다. 예 : 나는 각각 메시지를 순차적으로 만들어 내고 하나 이상의 파티션이있는 카프카 (Kafka) 주제에 글쓰기를하는 여러 메시지 생성자를 갖고있다. 이 경우 소비자 그룹이 메시지를 소비하는 방법.

0열

1답변

Golang Kafka가 모든 메시지를 사용하지 않음 offsetnewest

첫 번째 일괄 처리 : - 100 개의 플랫 파일에서 데이터를 가져 와서 배열로로드하고이를 kafka 제작자에게 하나씩 바이트 배열로 삽입하려고합니다. 두 번째 일괄 처리 : - kafka 소비자에서 소비 한 다음 NoSQL 데이터베이스에 삽입하고 있습니다. 저는 Kafka의 shopify sarama golang 패키지의 구성 파일에서 Offsetnews