Powershell로 변환하려고하는 C# 코드 조각이 있습니다. using (var consumer = new Consumer<Ignore, string>(config, null, new StringDeserializer(Encoding.UTF8))
나는 <>() 처리 할 수있는 방법 - 객체 인스턴스화에 참여? PowerShell의
나는 (나머지 API와 스키마 레지스트리가있는) Confluent에서 Apache Kafka를 설치했습니다. 나는 spring-boot와 spring-kafka를 사용하여 프로듀서를 구현했다. (각 이벤트는 데이터베이스 트리거에서 생성된다.) 이제는 여러 인스턴스로 실행하고 싶습니다.하지만 kafka에서 중복을 생략하는 적절한 방법은 무엇입니까? 로드 밸런
우리가 스프링 카프카-2.0.1.RELEASE를 사용하여 생산이 오류를 얻을 수 있습니다 : 예외 java.lang.NullPointerException이 java.lang.NullPointerException이를 : 널 (null) org.springframework.kafka.listener.KafkaMessageListenerContainer $ Li
카프카 스트림을 사용하여 시계열 데이터를 처리하고 있습니다. 하나의 사용 사례는 각 센서에 대한 시간 단위로 데이터를 집계하는 것입니다 (센서 ID는 항목 test의 메시지 키입니다). 키 (센서 ID)별로 그룹화 한 파이프 라인을 작성한 다음 매 시간마다 판독 값을 계산합니다. test 항목 (동일한 센서 ID 및 타임 스탬프)에 몇 가지 중복 메시지가있
@KafkaListener 주석을 기반으로 맞춤 메타 주석을 만들려고하지만 spring-kafka가 오류를 발생시킵니다. 가 여기 내 주석의 : @Target({ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Doc
카프카 제작자 비동기 또는 동기화 API를 사용해야한다면 망설이지 만 ASync API를 선호하지만 예외가있을 경우이를 잡기가 어렵습니다. 실패한 메시지를 기억하고 데이터베이스에 저장하는 콜백 기능을 작성했습니다. Sync API를 사용하는 경우 몇 가지 예외 클래스를 설계하고 적절한 예외 처리기 논리를 사용해야합니다. 그래서 실패 처리 관점에서 어떤 AP
스키마 레지스트리 서버를 사용할 때 같은 주제의 스키마를 더 이상 변경할 수 없습니다. 하지만 스키마 레지스트리가 없으면 각 레코드는 내부에 자체 스키마가 있으므로 언제든지 스키마를 쉽게 변경할 수 있습니다. 그럼 스키마 레지스트리 서버를 사용할 때 어떻게 스키마를 변경할 수 있습니까?
카프카 스트림을 사용하여 두 가지 주제에 참여하고 싶습니다. 두 가지 주제는 서로 다른 형식의 데이터를 가지고 있으므로 다른 타임 스탬프 추출기를 사용하고 싶습니다. 이 기능 (KAFKA-4144)에 대한 병합 된 pullrequest가 있었지만 프로세서 API에 대해서는 only find it입니다. Stream API에이 기능이 있습니까?