spring-xd

0열

2답변

스프링 XD 토끼 소스 모듈이 메시지를 처리하지 못합니다. 첫 번째 메시지는 수신 미확인 상태입니다.

간단한 봄 XD 응용 프로그램을 사용하여 HDFS에서 로그 이벤트를로드하려고합니다. 로그 메시지를 사전 구성 된 교환기로 보내려면 spring-ampq/rabbit log4j appender (org.springframework.amqp.rabbit.log4j.AmqpAppender 클래스)으로 대상 응용 프로그램을 구성했습니다. 나는에서 그 메시지를 가져

2열

1답변

Spring-XD는 한 번에 둘 이상의 JMS 브로커를 수신 할 수 있습니까?

하나의 JMS 브로커에서 데이터가 들어오는 시나리오에서 Spring Xd가 작동하도록했습니다. 다른 소스에서 데이터 처리가 발생할 수 있으므로 다른 브로커에 연결해야하는 상황에 직면 할 가능성이 있습니다. 현재 이해하고있는 바에 따르면 하나의 브로커 만 설정할 수있는 JMS 구성 파일이 있으므로이 작업을 수행하는 방법을 잘 모르겠습니다. 해결 방법이 있습니

2열

1답변

출력 채널에 메시지를 필터링하는 Spring-XD 프로세서 모듈을 만드는 방법은 무엇입니까

자바에서는 변환기 등을 쓰는 방법에 대한 예제가 많이 있지만 필터에 대해서는 아무것도 사용하지 않습니다 (스크립트 유형 필터 제외). 자바 메소드). 소스에서 싱크대까지 메시지의 페이로드를 필터링하는 사용자 지정 Java 필터를 만들고 싶습니다. 필터의 예는 모두 표현식을 나타냅니다. (어떻게) 표현식으로 지정된 클래스의 자바 메소드를 실행하도록 컨텍스트를

0열

1답변

spring-xd가 Eclipse 설명서를 통해 실행 중입니다.

Eclipse를 통해 SingleNodeApplication을 실행하여 spring-xd 단일 노드를 시작할 수 있었지만 브라우저를 관리 응용 프로그램으로 보내려고하면 403 오류가 발생합니다. 앞서 가서 그 원인을 조사하기 위해 시간을 보내기 전에 spring-xd 팀이 Eclipse IDE를 통해 spring-xd를 실행하기 위해 어떤 연습/프로세스를

0열

1답변

스프링 XD 스트림은 빈 .tmp 파일 만 생성합니다.

Hortonworks Sandbox VM에서 Spring-XD를 사용하려고합니다. xd:>stream create --name ticktockhdfs --definition "Time | HDFS" xd:>stream destroy --name ticktockhdfs xd:>hadoop fs ls /xd/ticktockhdfs -rw-r--r-- 3

2열

2답변

Spring에서 Greenplum 사용하기

Spring 프로젝트 중 어떤 것이 Greenplum에 삽입하거나 Greenplum으로 작업하기위한 템플릿이나 유틸리티를 제공합니까? Spring 배치를 사용하여 Tasklet에서 Greenplum gpload 유틸리티를 호출하여 지정된 파일을 데이터베이스에 삽입하는 방법이 있다는 것을 알고 있습니다. 그러나 Spring Data와 Spring XD 프로젝

0열

1답변

스프링 xd 스트림 정의 동적 매개 변수

일부 데이터를 HDFS에 저장하려면 HDFS 싱크를 사용해야합니다. 스트림 정의를 만들 때 "directory"속성을 사용하여 파일을 저장할 hdfs 디렉토리를 지정할 수 있습니다. 그러나 우리의 유스 케이스에서는 타임 스탬프에 따라 디렉토리가 동적이되기를 원한다. 어쩌면 헤더에서 타임 스탬프를 추출하기 위해 HDFS 싱크의 디렉토리 속성에 SpEL을 사용

0열

1답변

Spring-XD가 작업 실행을 처리하는 방법

정보를 문서에서 가져올 수 없습니다. Spring-XD가 어떻게 업무를 수행하는지 알려줄 사람이 있습니까? 특정 컨테이너에 작업을 할당하고 배포 된 컨테이너에서만이 작업을 실행합니까? 아니면 각 작업이 다른 컨테이너에 할당되어 있습니까? 특정 작업이 병렬로 (다른 인수로) 실행될 수 있고 다른 작업이 수행되지 않을 수도 있음을 어떻게 든 제어 할 수 있습니

2열

1답변

스트림 | 프로세서 및 스레드 모델

spring-xd가 스트림의 프로세서를 어떻게 처리하는지 궁금합니다. 내가 정말로 알고 싶은 것은 프로세서가 코드를 차단하는지 아니면 프로세서 (reactor) (https://github.com/reactor/reactor/wiki/Processor)가 프로세서를 다루는 지에 관한 것입니다. 값 비싼 블로킹 작업 (일명 외부 시스템 호출)을 실행해야하는

0열

1답변

Spring XD Failover

분산 모드에서 실행 중일 때 Spring XD는 자동 장애 조치를 지원합니까? 지금은 두 개의 컨테이너가있는 설치에서 간단한 스트림을 만들면 소스가 한 컨테이너에 배포되고 싱크가 다른 컨테이너에 배포됩니다. 두 번째 컨테이너를 종료하면 스트림이 배포 된 것으로 나열됩니다. 스트림을 다시 배포 취소하고 배포하면 예상대로 소스 및 싱크가 하나의 컨테이너에 배포