spring-kafka

0열

1답변

ConcurrentMessageListenerContainer가 동시 작동하지 않습니다.

다중 스레드 수신기를 만들려고하지만 모든 메시지가 동일한 스레드에서 실행됩니다. KafkaListerContainerFactory가 (올바르게) 인스턴스화 한 것이라도, 스레드 ID는 항상 동일하게 실행됩니다. 7 개의 메시지를 거의 동시에 보내면 처음 세 개는 동시에 처리하고 그 다음 세 개는 동시에 처리 한 다음 마지막 세 개는 동시에 처리 할 것으로

spring-boot apache-kafka spring-kafka 2017-12-19

---

1열

1답변

Spring-Kafka Consumer KafkaListener가 GenericMessage를 Java 객체로 변환 할 수 없습니다.

다음 두 단계를 사용하여 CentOS7 인스턴스의 Confluent-3.3.0 플랫폼에서 실행중인 kafka-rest 서비스를 통해 'InventoryEvent'사용자 정의 Java 유형의 이벤트를 게시합니다. 카프카 받침대 curl -X POST -H "Content-Type:application/vnd.kafka.json.v2+json" --data '

spring-boot apache-kafka spring-amqp spring-kafka 2017-12-19

---

2열

1답변

spring-kafka 2.1.0 및 SpringBoot 1.5.9를 사용하는 Kafka 소비자의 java.lang.NoSuchMethodError

SpringBoot (1.5.9) 및 Spring-kafka (2.1.0)를 사용하여 Kafka Consumer를 설정하려고합니다. 그러나 내 응용 프로그램을 시작할 때 java.lang.NoSuchMethodError : org.springframework.util.Assert.state (ZLjava/util/function/Supplier;) V를 K

spring-kafka 2017-12-20

---

0열

2답변

log4j를 사용하여 로그에 spring kafka 구성을 인쇄하는 방법

log4j를 사용하여 모든 spring-kafka 구성을 로그에 기록하는 방법이 있습니까? 내 log4j2.yml 응용 프로그램에서 다음 로거 구성을 사용해 보았습니다. 모든 정보와 디버그 로그를 볼 수 있지만 구성은 볼 수 없었습니다. - 이름 : org.springframework.kafka 가산 : 거짓 수준 : 정보/디버그 AppenderRef :

logging properties apache-kafka spring-kafka 2017-12-20

---

0열

1답변

kafka 바인더로 봄철 구름 스트림을 사용하여 메시지의 우선 순위를 지정하는 방법

TLDR : 같은 주제의 다른 사람들보다 먼저 긴급한 메시지를 처리하고 싶습니다. 더 설명 : 나는 몇 가지 작업을 위해 서로간에 이야기 할 수있는 카프카 - 바인더와 스프링 클라우드 스트림에 의존하는 많은 봄 microservices를 사용하여 상당히 큰 응용 프로그램에서 일하고 있어요 . 예약 된 작업으로 인해 많은 이벤트가 발생할 수 있습니다. 이러한

spring-cloud-stream spring-kafka 2017-12-22

---

1열

2답변

봄 카프카 프로듀서 내가 로컬 카프카를 설정이 고정 표시기-작성 설정을 사용하고

을 (매직 V1 레코드 헤더를 지원하지 않습니다) 카프카 1.0.0로 전송하지 벌금. o.a.kafka.common.utils.AppInfoParser : Kafka version : 1.0.0 o.a.kafka.common.utils.AppInfoParser : Kafka commitId : aaa7af6d4a11b29d 내가이 kafkaTemp

spring spring-boot apache-kafka docker-compose spring-kafka 2017-12-23

---

0열

2답변

org.apache.kafka.common.KafkaException : kafka 소비자를 생성하지 못했습니다.

수동으로 Zookeeper를 시작한 다음 Kafka 서버를 시작하고 마지막으로 Kafka-Rest 서버를 해당 속성 파일로 시작합니다. 다음으로는 톰캣 로그 추적에서 바람둥이 내 봄 부팅 응용 프로그램을 배포하고, 나는 오류 org.springframework.context.ApplicationContextException: Failed to start b

spring-boot apache-kafka kafka-consumer-api spring-kafka 2017-12-25

---

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"를 정의했습니다. 봄 카프카에서 트랜잭션을 사용하려면이 작업을 수행해야합니다.하지만

apache-kafka spring-cloud-stream spring-kafka 2017-12-27

---

2열

1답변

KSQL 테이블의 데이터 읽기

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

apache-kafka apache-kafka-streams apache-kafka-connect spring-kafka ksql 2017-12-27

---

0열

1답변

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

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

apache-kafka kafka-consumer-api kafka-producer-api apache-kafka-connect spring-kafka 2017-12-29

---