spring-kafka

2열

2답변

여러 주제에 대한 봄 카프카 단일 제작자

여러 주제에 JSON 객체를 작성하는 데 단일 제작자를 사용하고 싶습니다. 다음 코드는 내가하고 싶은 일을하고 있지만 KafkaTemplate에 메시지를 보내야한다고 알리는 데는 setDefaultTopic() 메서드를 사용하는 것이 잘못되었습니다. 보다 send(String topic, ? payload) 방법을 사용하면 작동하지 않습니다. 내 프로듀서

java spring spring-kafka 2017-09-06

---

1열

1답변

org.apache.kafka.clients.NetworkClient 부트 스트랩 브로커 bootstrap-servers-ip : 9092 disconnected

로컬 시스템에 apache kafka를 실행 중이며 절대 실행 중입니다. 하지만 연기 테스트를하는 동안 내 응용 프로그램은 카프카 클러스터에 연결할 수 없습니다. 그것은 끝없이 다음과 같은 오류를 던지고 계속 : [2016-11-22T23:04:35,017][WARN ][org.apache.kafka.clients.NetworkClient] Bootstra

apache-kafka apache-zookeeper kafka-consumer-api spring-kafka 2017-09-07

---

0열

1답변

파티션에 대한 키/값의 역 직렬화

키없이 카프카 항목으로 보낼 때 통합 테스트가 있습니다. 그러나 키를 추가 할 때 serialization 오류가 발생하기 시작합니다. org.apache.kafka.common.errors.SerializationException: Error deserializing key/value for partition topic-1 at offset 0 Cau

java spring-boot apache-kafka spring-kafka 2017-09-08

---

0열

1답변

Kafka 리스너 (spring-kafka)가 초기화되지 않아도 스프링 응용 프로그램을 시작하는 방법

나는 spring-kafka를 사용하는 Kafka 리스너를 사용하는 응용 프로그램에서 작업하고 있습니다. 내가 겪고있는 문제는 Kafka 리스너가 켜지지 않을 때 스프링 컨텍스트 초기화가 실패한다는 것입니다. Kafka 서버가 켜져 있지 않거나 다운 된 것과 같은 다양한 이유가 있습니다. 내 신청서가 독립적인지 어떻게 확인할 수 있습니까? 아무도 도와 줄

spring spring-kafka 2017-09-10

---

0열

2답변

Spring Kafka 파티션을위한 여러 소비자

우리는 봄 카프카를 사용하여 메시지를 소비합니다. 각 파티션마다 메시지를 수신 할 수있는 수신기를 만들었습니다. 이제는 단일 파티션에서 소비자 메시지에 둘 이상의 수신기가 필요한 요구 사항이 있습니다. 파티션 0이 있다고 가정 해 봅시다. 현재 우리는이 파티션에서 메시지를 수신하는 수신기 (Receiver 1)가 하나뿐입니다. 이제 같은 파티션 (파티션 0

apache-kafka kafka-consumer-api spring-kafka 2017-09-10

---

0열

2답변

kafka 생산자/소비자가 다시 시작된 후 소비자가 메시지를 수신하지 않음

하나의 생산자 & 한 명의 생산자가 있습니다. & 한 파티션. 소비자/생산자 모두 스프링 부트 응용 프로그램입니다. 소비자 응용 프로그램은 내 로컬 컴퓨터에서 실행되며 생산자는 kafka & 사육사와 함께 원격 컴퓨터에서 실행됩니다. 개발하는 동안 일부 제작자 응용 프로그램을 재배포했습니다. 하지만 그 후 내 소비자는 어떤 메시지도받지 못합니다. 나는 소비

java apache-kafka spring-cloud-stream spring-kafka 2017-09-12

---

1열

1답변

스프링 @Bean을 사용하여 카프카 토픽을 만드시겠습니까?

스프링 빈을 사용하여 카프카 토픽을 만들 수 있습니까? 우리가 RabbitMQ의 Queue와 TopicExchanges를 가지고 있고 이것들은 프로그래밍 방식으로 생성 될 수 있습니다. @Bean Queue queue(){ return new Queue("name"); } 설명서가 도움이되지 않습니다.

spring-boot apache-kafka spring-kafka 2017-09-15

---

1열

1답변

스프링 카프카 | 나는 사용자 ID가 삭제됩니다 항목 이름 "사용자"가

같은 메시지를 읽고, 나는 기능 내가 동일한 주제를 가리키는 두 개의 리스너를 가지고 읽을 수 1. process user leave data 2. process user salary data 아래에이 주제와 과정에서 읽고 싶어 동일한 사용자 ID와 병렬 처리로 초기화하십시오. processPayRoll 모든 시간을 호출지고 - @KafkaListen

spring spring-boot apache-kafka spring-kafka 2017-09-19

---

1열

1답변

스프링 카프카 -Consumer가 인식하지 못하는 메소드를 호출합니다.

청취자 클래스에 ConsumerSeekAware을 구현 중입니다. 그러나 overridden 메소드 registerSeekCallback, onPartitionsAssigned, onIdleContainer는 결코 호출되지 않습니다. 아래는 내 소비자 구성 및 소비자 파일입니다. 실수를 식별 할 수 없습니다. Spring-kafka : 1.1.6 버전을 사

spring-kafka 2017-09-20

---

0열

1답변

수동 커밋을 위해 Spring Kafka의 Acknowledgement.acknowledge() 메소드를 사용하는 방법

스프링 카프카를 처음 사용하고 있으며 여기에서 언급 한 것처럼 내 소비자 코드에서 Acknowledgement.acknowledge() 메소드를 수동 커밋에 사용할 수 없습니다. https://docs.spring.io/spring-kafka/reference/html/_reference.html#committing-offsets. 내 것은 스프링 부트 응

java spring-boot kafka-consumer-api spring-kafka 2017-09-20

---