spring-cloud-dataflow

1열

1답변

스프링 클라우드 스트림 바인더 kstream-1.3.0 : 스프링이없는 IllegalAccessError 클라우드 스트림 바인더 kstream과 노력을 그 슈퍼

액세스 할 수 1.3.0.RELEASE 버전 의 pom.xml : <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLoc

0열

1답변

stdout 및 stderr 작업 파일 디렉토리를 변경하는 방법은 무엇입니까?

Linux에서 작업 실행을위한 spring-cloud-dataflow 로컬 서버 로그는/tmp/spring-cloud-dataflow- *입니다./tmp가 아닌 다른 곳에서 만들어 질 작업 별 디렉토리가 필요합니다. 예. 대신 /tmp를/{수}/{작업 이름} - 클라우드 dataflow- 봄 - {수}/{작업 이름} - {UUID} 이 그것을 유무 : /옵

-3열

1답변

레디 스 연결 실패 예외가 수신

: Failed to perform redis operation. org.springframework.data.redis.RedisConnectionFailureException: Cannot get Jedis connection; nested exception is redis.clients.jedis.exceptions.JedisConnectionEx

0열

1답변

스프링 관리 기능을 추가하기 위해 로컬 서버에서 스프링 클라우드 데이터 흐름과의 통합 스프링

스프링 부트의 임베디드 Apache Tomcat에서 실행되는 기본 스프링 배치 응용 프로그램이 있습니다. 스프링 관리 기능을 추가해야합니다. 최신 스프링 문서에 따르면 스프링 클라우드 데이터 흐름을 사용하여이 작업을 수행해야합니다 (https://docs.spring.io/spring-batch-admin/). 이제 스프링 클라우드 데이터 흐름을 사용하고

1열

1답변

스프링 클라우드 스트림 시간 기반 자동 커밋을 사용하는 Kafka 소비자

카프카 바인더를 사용하는 Spring Cloud Stream 앱이있다. AckMode=BATCH을 기준으로 자동으로 오프셋을 커밋하는 것 같습니다 (디버깅 모드에서 문서화되어 나타나지 않아야합니다). 이로 인해 커밋 빈도가 중개인에게 상당한 오버 헤드가 발생합니다. 여기에 설명 된대로 enable.auto.commit: true auto.commit.in

0열

1답변

봄 구름 데이터 흐름 파일을 찾을 수 없습니다

springboot에 마이크로 서비스를 만들었습니다. 리소스 폴더 아래에 폴더가 있고이 폴더 아래에 파일이 있습니다. i, e. 내가 그것을 파일을 작동하고이 springboot 응용 프로그램을 실행하고 때 resource mycustomfolder myfile.txt 내가 myfile @Value("${file-path}")

0열

2답변

프로세서가 동일한 페이로드로 여러 번 메시지를 여러 번 수신합니다.

저는 'spring-cloud-dataflow'라는 새로운 프로젝트를 시작하여 필요에 맞게 병을 개발했습니다. 이 파일 중 하나는 파일 소스의 파일을 untar 처리하는 프로세서이며,이 응용 프로그램은 tar 및 gunzip 파일 압축을 처리하는 기능이있는 integration-zip의 사용자 정의 버전을 사용합니다. 내 문제는 다음과 같습니다. 내 소스가

0열

1답변

Spring Cloud DataFlow : 목록으로 페이로드 받기

Spring Cloud DataFlow 1.3.0.M2와 Spring Cloud Stream Starters 사용 Celsius.M1. 두 개의 프로세서가 있습니다. 먼저 List<Map>을 생성하며 다른 쪽에서 소비해야합니다. 다음은 간단한 코드입니다. // Processor 1 @StreamListener(Processor.INPUT) @SendTo

0열

1답변

스프링 클라우드 스트림 소스를 확인하고 데이터 컨텐츠를 싱크하는 방법

스프링 클라우드 데이터 플로우 스트림 소스에 어떤 데이터가 있는지 확인할 수있는 방법이 있습니까 (예 : "mySource"라는 일부 대상) 및 싱크 ("싱크")? e.g. dataflow:>stream create --name demo --definition ":mySource>log" 여기 mySource 및 로그에 무엇이 있는지 확인하는 방법은 무

1열

1답변

DLQ에 예외가 포함되지 않았습니다.

kafka 바인더가있는 스프링 클라우드 스트림을 설정했습니다. 또한 DLQ를 사용 가능하게 설정하고 here과 같이 예외 메시지를 캡처하도록 headerMode를 설정했습니다. 그러나 예외가있을 때 예외 정보없이 내 카프카 주제의 메시지 만 볼 수 있습니다. 내 application.yml는 (0.11 이전) - 카프카에게 스프링 클라우드 스타터 스트림이