spring-kafka

1열

1답변

DefaultPartitioner를 Spring-kafka kafkaTemplate의 sendDefault 메소드와 함께 사용하는 방법

4 개의 파티션이있는 항목에 메시지를 보내려고합니다. 그리고 DefaultPartitioner에 의해 결정된대로 메시지를 보내려고합니다. kafkaTemplate.sendDefault(DefaultPartitioner(job.getId()),job.getId(),job); kafkaTemplate이 DefaultPartitioner를 사용하여 파티션 번호를

2열

1답변

@KafkaListener 주석을 사용할 때 오프셋을 재설정하는 표준 방법이 있습니까?

스프링 부트 응용 프로그램에서 KafkaListener 인터페이스를 사용하고 있습니다. 정상적으로 작동합니다. 오프셋은 카프카 자체에 의해 저장됩니다. 이제 주제의 소비자 중 한 명이 새 버전을 배포하고 2 시간 분량의 메시지를 스크루라고 말합니다. 그런 다음 앱을 수정하고 2 시간 전에 오프셋 된 새 버전을 시작하려고합니다. 이전 consumer.offs

0열

2답변

spring kafka에서 소비자와 리스너를 이해하는 방법

spring kafka를 멀티 스레드 기능 (ConcurrentKafkaListenerContainerFactory)과 함께 사용하면 다음과 같은 두 가지 유형의 스레드 이름을 찾을 수 있습니다. 1. # 0-1-kafka-consumer-1 2 # 0-1-kafka-listener-3 이렇게 두 종류의 스레드를 어떻게 이해할 수 있습니까? 그들 사이의 관

0열

2답변

스프링 통합 Kafka가 작동하지 않습니다.

저는 Kafka와 Spring Boot를 사용하여 Spring Integration을 탐색하려고합니다. 나는이 튜토리얼 내가 그 문서에서 제공되는 종속성을 사용하고 Spring Integration and Kafka 을 다음 있어요,하지만 난 다음 예외 Caused by: org.xml.sax.SAXParseException: cvc-complex-type

0열

1답변

Kafka 소비자가 맞춤 그룹에 가입하지 못했습니다.

저는 Spring 카프카 문서에 따라 Kafka ConsumerFactory를 설정했습니다. 그러나 groupId가 사용되지 않는 것 같습니다. 어쩌면 나는 또한 모든 것을 잘못하고있어서 내가 경험 한 것을 당신에게 알려주고 싶었을 것입니다. 이이 작동하지 않는 것 내 구성입니다 : @Bean ConsumerFactory<String, KafkaEvent

4열

1답변

kafka는 재조정 후 할당 된 새 파티션에서 메시지를 사용하지 않습니다.

저는 kafka (영어로도 ...)가 처음인데, 나는이 문제에 직면 해 있으며 어떤 해결책도 찾을 수 없습니다. 나는 으로 주제를 만들 s1.then (하나의 브로커 0) 내 로컬 컴퓨터에 봄 부팅, 스프링 카프카 지원, 내가 설치 한 kafka_2.11-0.10.1.1를 사용 bin/kafka-topics.sh --create --zookeeper loc

1열

1답변

유효하지 않은 UTF-8 중간 바이트 0x72

spring-kafka에서 JsonSerializer 및 JsonDeserializer를 사용하여 메시지를 생성하는 동안 값 직렬기를 설정하고 있습니다. 메시지에는 특수 문자 (독일어 움라우트)가있는 하나의 필드 (orgName)가 있습니다.이 특수 문자는 어떻게 처리합니까? JsonDeserializer가 jackson을 사용하고 jackson이 utf-

-1열

1답변

Spring kafka 1.1.2와 Spring framework 3.1.1 사용하기

저는 스프링 통합과 스프링 카프카에 대해 상당히 새롭습니다. kakfa에 대한 제작자를 작성해야하며 봄 kafka 1.1.2 (이전에 사용한대로)를 사용하려고 계획하고 있으며 부모 프로젝트는 스프링 프레임 워크 3.1.1을 사용하고 있습니다. 어떻게 작성합니까? 스프링 kafka 1.1.2에 대한 XML 구성은 설명서에서 아무것도 찾을 수 없었습니다. 또한

0열

1답변

카프카 소비자를 만들 수 없습니다.

저는 스프링 카프카를 사용하고 있으며 카프카 소비자를 만들고자합니다. 나는 참조 번호 http://howtoprogram.xyz/2016/09/23/spring-kafka-tutorial/ 과 https://www.codenotfound.com/2016/09/spring-kafka-consumer-producer-example.html을 가져갔습니다. 현재

1열

1답변

스프링 부트 : 일부 자동 구성 빈을 제외합니다.

스프링 - 카프카를 사용하는 스프링 부트 프로젝트가 있습니다. 이 프로젝트에서 스프링 - 카프카 콩 (즉, KafkaTemplate 및 ConcurrentKafkaListenerContainer)을 래핑하는 이벤트 중심의 구성 요소를 구축했습니다. 이 프로젝트를 스프링 부트 애플리케이션 세트 전체에서 재사용 가능한 라이브러리로 만들고 싶습니다. 나는 봄 부