카프카 커넥트 재실행시 저는 my-sink-connect와 my-source-connect가 안남는데
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
유지하는 설정이 따로있을까요?
- spring-boot
- jpa
- 아키텍처
- spring-cloud
- kafka
- msa
172만명의 커뮤니티!! 함께 토론해봐요.
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
유지하는 설정이 따로있을까요?
미해결
파이참으로 100~200 까지 3의 배수 인쇄하고, 그의 합 구하고 있는데 3의 배수 5개씩 인쇄는 잘 했는데 합계가 이상하게 구해집니다. 오류가 어디에 있는 건지 모르겠어요.. 고치면 오류떠서 아예 실행이 안되는데 ㅜㅜ for문이랑 while문 두개로 만들고 있는데 둘다 합계만 이상하게 뜹니다. ㅠ <<for문>> a = 0 hap = 0 count = 0 for a in range(100, 201) : if a % 3 == 0 : print(a) count = count + 1 if count % 5 == 0 : print() a = a + 1 hap = hap + a print("100~200 중 3의 배수의 합 : %d" % hap) <<while문>> a = 100 count = 0 hap = 0 while a <= 200 : if a % 3 == 0 : print(a) count = count + 1 if count % 5 == 0 : print() a = a + 1 hap = hap + a print("100~200 중 3의 배수의 합 : %d" % hap)
미해결
[리뉴얼] 처음하는 파이썬 백엔드와 웹기술 입문 (파이썬 중급, flask[플라스크] 로 이해하는 백엔드 및 웹기술 기본) [풀스택 Part1-1]
위에 코드와 같이 웹서버를 열 때 처음 실행만 정상적으로 뜨고 두 번째부터는 로드중으로 계속 화면에 아무것도 안 뜹니다. 주피터 노트북과 아나콘다 프로그램을 완전히 종료하고 다시 접속해 위에 코드를 입력하면 다시 처음만 정상실행되고 두번째부터는 무한로드중으로 뜹니다. 다른 컴퓨터로 실행해봤을 때는 정상적으로 화면에 출력되는 것을 확인했고 제 노트북만 이러네요. 이거 때문에 아나콘다도 다시 설치해보고 윈도우에 내장되어 로컬호스트 주소도 확인하고 윈도우도 재설치해보고 컴퓨터 자체를 포맷해봤는데도 계속 같은 증상이네요. 혹시 문제가 무엇일까요? 이거 때문에 수업 진도를 못 나가고 있어요. 도와주세요ㅠㅠ
해결됨
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
좋은 강의 감사드립니다. 덕분에 많은 걸 배워서 마음이 든든해 집니다. 그런데, 하나 궁금한 점이 있어서 여쭤보고 싶습니다. 우리 개발자들은 사실 귀찮은 걸 싫어하기 때문에 기술이 나날이 발전해 가는 것이라 생각이 되는데요, 강사님이 설명주신 부분처럼 Schema나 Payload를 계속해서 수동으로 만드는 것은 개발자 입장에서는 매우 비효율적일거라 생각이 됩니다. 따라서, 이미 저 부분을 해결하기 위한 많은 부분들이 고려되었을 것으로 예상이 되는데요, 혹시 저 부분을 편하게 등록할 수 있는 다른 방법이 있을까요? 키워드라도 주시면 찾아서 공부해 나가는데 큰 도움이 될 것 같습니다. 감사합니다.
미해결
모든 개발자의 실무를 위한 올인원 기본기 클래스
강의 자료 링크가 동작이 안되는데 확인 부탁 드립니다!
미해결
안녕하세요 colab을 이용하던 도중에 갑자기 이상한 현상이 생겨서 질문 남깁니다! 영어를 사용하면 별 문제가 없는데 이상하게 한글만 사용하면 글씨색도 변하고 위의 사진 처럼 셀의 화면이 내려가거나 확대 됩니다. 주석뿐만 아니라 코드에도 한글을 넣으면 똑같은 현상이 발생합니다. 작성시에는 화면이 보이지 않지만 작성후 방향키나 공백을 넣으면 다시 원래 화면으로 돌아옵니다. ㅠㅠㅠㅠ 너무 거슬려서 주석을 작성 할 수 가 없습니다ㅠㅠㅠ 해결책이 있을까요 이것저것 옵션 다 만져봤지만 해결이 안돼서 여쭙니다.
해결됨
코딩테스트 [ ALL IN ONE ]
해당 코드에서 LCA에 첫번째 인자값에 배열을 넣어주는데 LCA의 함수에서 root는 left와 right를 가지고 있습니다. 무엇인가요...
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
지금 제가 도커를 먼저 알고 싶어서 카프카까지 다 들은후 도커부터 듣는 중인데요. 근데 카프카할때부터인가 test를 다 안하고 넘기는 설정을 하시는거 같은데 왜 이렇게 하시나요?? 이게 실제 운영환경이라면 이렇게 못하잖아요?(테스트 코드가 있을 수도 있으니까요) 어떤걸 참고하면서 하면 이 상황을 타개해 나갈수 있을까요?
미해결
[개정판] 파이썬 머신러닝 완벽 가이드
graphviz 설치하고 실습파일 4-2의 3번째줄까지 코드를 작성하면 '[Errno 13] Permission denied: PosixPath('dot')' 가 발생합니다. 해결방법을 알 수 있을까요?
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
랜덤 포트를 지정하는게 좋다고 설명해주셨는데요 Kakao login OAuth2 를 사용해서 로그인하는 경우 Redirect URI를 지정해야합니다. Gateway 주소( http://localhsot:8080/user-service/api/...)를 등록해도 결국 localhost:54241 이렇게 넘어 가기 때문에 에러가 발생하는데 이 경우에도 랜덤 포트 사용하는게 맞나요?
미해결
파이썬을 통해 음성 wave파일에서 주파수 값을 추출해서 array 등으로 계산할 수 있도록 하려고 합니다. 그렇게 해서 주파수 대역폭 (최대 - 최소)를 값으로 구하고 싶은데 아무리 구글링을 해도 안나오네요 ㅜㅜ 뭘써야할까요..>?
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
windows 10, eclipse에서 수업을 따라하고 있습니다. 서버 동작도 안 되었는데 .m2파일 중 configu와 관련된 내용 지우고 이클립스 다시 시작하니 config서버가 동작은 합니다. 그런데 git 레파지토리에 있는 ecommerce.yml파일을 읽지 못 하는지, 아니면 자신이 일반 서버로 착각하는지 404 에러가 납니다. 이미지를 첨부했습니다. 어떻게 해야 이 고통에서 벗어날 수 있을까요? 동영상 강의 보면, 쉽게 배울 수 있을 거라 생각했는데 동영상 강의 촬영일과 2년 정도 차이가 나니 이런 저런 걸로 계속 에러가 나네요.
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
안녕하세요 강사님! 강의 잘보고 있습니다. 강의시간 18:58에 sink 생성 후 status 확인 값에서 tasks.state 값이 failed라고 뜹니다. 그래서 connect 로그를 보면 아래와 같이 뜹니다. [2023-05-02 00:04:12,636] ERROR [my-order-sink-connect|task-0] WorkerSinkTask{id=my-order-sink-connect-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted (org.apache.kafka.connect.runtime.WorkerTask:196) org.apache.kafka.connect.errors.ConnectException: Tolerance exceeded in error handler at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:223) at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execute(RetryWithToleranceOperator.java:149) at org.apache.kafka.connect.runtime.WorkerSinkTask.convertAndTransformRecord(WorkerSinkTask.java:516) at org.apache.kafka.connect.runtime.WorkerSinkTask.convertMessages(WorkerSinkTask.java:493) at org.apache.kafka.connect.runtime.WorkerSinkTask.poll(WorkerSinkTask.java:332) at org.apache.kafka.connect.runtime.WorkerSinkTask.iteration(WorkerSinkTask.java:234) at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:203) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:189) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:244) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.kafka.connect.errors.DataException: JsonConverter with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. If you are trying to deserialize plain JSON data, set schemas.enable=false in your converter configuration. at org.apache.kafka.connect.json.JsonConverter.toConnectData(JsonConverter.java:328) at org.apache.kafka.connect.storage.Converter.toConnectData(Converter.java:88) at org.apache.kafka.connect.runtime.WorkerSinkTask.lambda$convertAndTransformRecord$4(WorkerSinkTask.java:516) at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndRetry(RetryWithToleranceOperator.java:173) at org.apache.kafka.connect.runtime.errors.RetryWithToleranceOperator.execAndHandleError(RetryWithToleranceOperator.java:207) ... 13 more 구글링 해봐도 원하는 답변들이 없어 남겨봅니다.
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
현재 학습하고 있는 스프링 버전은 3.0.5 버전입니다. implementation 'org.springframework.cloud:spring-cloud-starter-config' implementation 'org.springframework.cloud:spring-cloud-starter-bootstrap' 위 두개의 라이브러리를 추가한 후 bootstrap.yml 파일을 생성해서 아래와 같이 작성을 하면 spring: cloud: config: uri: http://localhost:8888 name: ecommerce 서버 실행 후 아래와 같이 로그가 출력됩니다. . ____ _ __ _ _ /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \ ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \ \\/ ___)| |_)| | | | | || (_| | ) ) ) ) ' |____| .__|_| |_|_| |_\__, | / / / / =========|_|==============|___/=/_/_/_/ :: Spring Boot :: (v3.0.5) 2023-05-01T17:24:26.009+09:00 INFO 81323 --- [ restartedMain] c.c.c.ConfigServicePropertySourceLocator : Fetching config from server at : http://localhost:8888 2023-05-01T17:24:26.117+09:00 INFO 81323 --- [ restartedMain] c.c.c.ConfigServicePropertySourceLocator : Located environment: name=ecommerce, profiles=[default], label=null, version=6bb0cd579b695bb651be6edc215d85335734c939, state=null 2023-05-01T17:24:26.117+09:00 INFO 81323 --- [ restartedMain] b.c.PropertySourceBootstrapConfiguration : Located property source: [BootstrapPropertySource {name='bootstrapProperties-configClient'}, BootstrapPropertySource {name='bootstrapProperties-file:///Users/..../git-local-repo/ecommerce.yml'}] name=ecommerce로 정상적으로 불러지고 있고, yml 파일 위치도 정상적으로 출력이 됩니다. 하지만 서버가 실행되다가 8888포트를 이미 사용을 하고 있다는 메시지와 함께 서버가 종료가 되었습니다. 검색을 해 보니 2.4버전대부터 설정하는 방법이 바뀌었다고 해서 변경된 방법으로 적용을 했습니다. bootstrap 라이브러리를 삭제했습니다. implementation 'org.springframework.cloud:spring-cloud-starter-config' bootstrap.yml 파일을 삭제했습니다. application.yml 파일에 내용을 추가했습니다. spring: config: name: ecommerce import: optional:configserver:http://localhost:8888 그리고 실행을 하면 아래와 같이 name=user-service로 적용이 됩니다. 2023-05-01T17:33:51.792+09:00 INFO 82127 --- [ restartedMain] o.s.c.c.c.ConfigServerConfigDataLoader : Fetching config from server at : http://localhost:8888 2023-05-01T17:33:51.792+09:00 INFO 82127 --- [ restartedMain] o.s.c.c.c.ConfigServerConfigDataLoader : Located environment: name=user-service, profiles=[default], label=null, version=6bb0cd579b695bb651be6edc215d85335734c939, state=null 이유가 application.yml 파일에서 config 설정 윗 부분에 spring: application: name: user-service 이렇게 application name을 설정을 해서 그렇게 나오는것 같습니다. 그리고 로그중에 아래와 같이 뜨는데 2023-05-01T17:33:51.793+09:00 INFO 82127 --- [ restartedMain] o.s.b.devtools.restart.ChangeableUrls : The Class-Path manifest attribute in /Users/.../.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-impl/4.0.1/bad26cea1d483dda57b6f634cdeaca3238637aea/jaxb-impl-4.0.1.jar referenced one or more files that do not exist: file:/Users/.../.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-impl/4.0.1/bad26cea1d483dda57b6f634cdeaca3238637aea/jaxb-core.jar,file:/Users/.../.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-impl/4.0.1/bad26cea1d483dda57b6f634cdeaca3238637aea/angus-activation.jar 2023-05-01T17:33:51.794+09:00 INFO 82127 --- [ restartedMain] o.s.b.devtools.restart.ChangeableUrls : The Class-Path manifest attribute in /Users/.../.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-core/4.0.1/e8bf2d711d2d4250537199602bccae0cd4e62726/jaxb-core-4.0.1.jar referenced one or more files that do not exist: file:/Users/.../.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-core/4.0.1/e8bf2d711d2d4250537199602bccae0cd4e62726/jakarta.activation-api.jar,file:/Users/.../.gradle/caches/modules-2/files-2.1/com.sun.xml.bind/jaxb-core/4.0.1/e8bf2d711d2d4250537199602bccae0cd4e62726/jakarta.xml.bind-api.jar 아래의 라이브러리중 어떤것을 설치를 해도 똑같은 로그가 출력됩니다. 파일이 존재하지 않는다는 내용인데.. INFO레벨로 출력이 되서 우선은 그냥 넘어갔습니다. implementation 'javax.xml.bind:jaxb-api:2.4.0-b180830.0359' // implementation group: 'javax.xml.bind', name: 'jaxb-api', version: '2.2.4' user-service를 실행을 시켜보면 아래와 같이 외부 설정 파일의 값을 읽어오지 못하고 있습니다. It's Working in User Service, port(local.server.port)=56942, port(server.port)=0, token secret=null, token expiration time=null 아래의 공식 문서도 참고를 해 봤는데 어느 부분이 잘못됐는지 모르겠더라구요.. https://docs.spring.io/spring-cloud-config/docs/current/reference/html/ 이 전단계의 git-local-repo 디렉토리를 만들어서 git을 commit까지 하는것은 정상적으로 됐고, 설정파일을 읽어오는것까지는 정상적으로 됐었습니다. 제 경우 한가지 이슈사항이 있던 부분은 git branch가 master로 되어있어서 오류가 나는 부분이 있어서 그 부분은 git branch를 main으로 하나 만들어서 적용을 하니 해당 오류는 해결이 됐었습니다. 최신 버전으로 적용을 할려고 하니 이리저리 쉽지가 않네요..
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
안녕하세요. 강의에서 config-service의 yml 파일 내 uri와 jks 파일의 위치를 바꿔서 docker에서 실행해도 강의에서 나왔던 오류가 발생합니다. bootstrap.yml encrypt: # key: abcdefghijkimnopqrstuvwxz0123456789 key-store: location: file:/apiEncryptionKey.jks password: test1234 alias: apiEncryptionKey jks 파일의 위치를 Dockerfile과 동일한 경로에 복사했습니다. application.yml server: port: 8888 spring: application: name: config-server rabbitmq: host: 127.0.0.1 port: 5672 username: guest password: guest cloud: config: server: native: search-locations: file://C:\work\springcloud\git-local-repo git: uri: https://github.com/mjjunng/spring-cloud-config management: endpoints: web: exposure: include: health, busrefresh docker 실행 로그 해당 에러를 확인해보면, 강의에서 파일의 위치를 변경하지 않았던 에러와 동일한 것으로 생각됩니다. 강의와 마찬가지로 파일 경로를 바꿔도 해당 에러가 발생하는데, 제가 놓친 부분이 있을까요?
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
강사님이 제공하기 파일로 진행하고 있었습니다. .\bin\windows\connect-distributed.bat . \etc\kafka\connect-distributed.properties 위의 명령어로 kafka connect을 실행하려하는데 아래와 같은 에러가 발생합니다. log4j:ERROR Could not read configuration file from URL [file:C:/Work/confluent-7.3.1/config/connect-log4j.properties]. java.io .FileNotFoundException: C:\Work\confluent-7.3.1\config\connect-log4j.properties (지정된 경로를 찾을 수 없습니다) at java.base/java.io.FileInputStream.open0(Native Method) at java.base/java.io.FileInputStream.open( FileInputStream.java:219 ) at java.base/java.io.FileInputStream.<init>( FileInputStream.java:157 ) at java.base/java.io.FileInputStream.<init>( FileInputStream.java:112 ) at java.base/sun.net.www.protocol.file.FileURLConnection.connect( FileURLConnection.java:86 ) at java.base/sun.net.www.protocol.file.FileURLConnection.getInputStream( FileURLConnection.java:184 ) at org.apache.log4j.PropertyConfigurator.doConfigure( PropertyConfigurator.java:557 ) at org.apache.log4j.helpers.OptionConverter.selectAndConfigure( OptionConverter.java:504 ) at org.apache.log4j.LogManager.<clinit>( LogManager.java:119 ) at org.slf4j.impl.Reload4jLoggerFactory.<init>( Reload4jLoggerFactory.java:67 ) at org.slf4j.impl.StaticLoggerBinder.<init>( StaticLoggerBinder.java:72 ) at org.slf4j.impl.StaticLoggerBinder.<clinit>( StaticLoggerBinder.java:45 ) at org.slf4j.LoggerFactory.bind( LoggerFactory.java:150 ) at org.slf4j.LoggerFactory.performInitialization( LoggerFactory.java:124 ) at org.slf4j.LoggerFactory.getILoggerFactory( LoggerFactory.java:417 ) at org.slf4j.LoggerFactory.getLogger( LoggerFactory.java:362 ) at org.slf4j.LoggerFactory.getLogger( LoggerFactory.java:388 ) at org.apache.kafka.connect.cli.ConnectDistributed.<clinit>( ConnectDistributed.java:59 ) log4j:ERROR Ignoring configuration file [file:C:/Work/confluent-7.3.1/config/connect-log4j.properties]. log4j:WARN No appenders could be found for logger (org.apache.kafka.connect.runtime.WorkerInfo). log4j:WARN Please initialize the log4j system properly. log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info. log4j 가 없다는거 같은데 어떻게 해결할지 알려주시면 감사하겠습니다..
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
안녕하세요, 제 질문은 아래와 같습니다. '강의를 시작하며' 수업에서 본 강의는 ' Spring Boot를 이용한 RESTful Web Services 개발' 강의의 후속 강의라고 말씀해주셨습니다. 기존에 Rest API를 알고 있음에도, ' Spring Boot를 이용한 RESTful Web Services 개발' 강의를 먼저 들어야만 할까요? 감사합니다.
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
DB 패스워드를 암호화하기 위해 key-store를 생성하게 되는데 여기에서도 key-store의 패스워드가 yml 설정파일에 존재하게 되는 것으로 이해했습니다. key-store의 패스워드는 암호화 하지 않아도 되는건지 헷갈려서 질문드립니다. 만약 암호화가 필요하다면 DB 패스워드를 암호화 하기 위한 key-store의 패스워드를 암호화 하기위한 key-store..... 이런식으로 무한루프가 돌 것 같은데 실무 환경에서는 어떻게 사용하고 있는지 궁금합니다.
해결됨
실전 금융 머신러닝: 파이썬으로 구축하는 중급 투자 전략
안녕하세요 예측에 관련되서 여쭤볼게 있어서 질문 드립니다. LSTM훈련 후 Original Price와 Predicted Price의 그래프를 그리실 때 자세히 보시면 Predict price가 Original price의 데이터를 1스탭 뒤로 그려지는 것을 볼 수 있습니다. 그렇다면 이건 예측이 아니라 전 스탭에 있는 데이터를 어느정도 이동평균 또는 지수 이동평균과 같이 보정해서 쓴다고 보는게 맞지 않을까요? 이렇게 나오는 것보다 완전히 맞지 않더라도 1스탭 뒤로 예측되는 예측되는 것보다 어느정도 맞게 따라가는 방법은 없을까요?
미해결
Spring Cloud로 개발하는 마이크로서비스 애플리케이션(MSA)
eureka.clinet.fetch-registry : true 의미가 클라이언트가 유레카 서버를 통해 다른 서비스 정보를 얻기을 수 있다고 알고있습니다. 여기서 궁금한 점이 있는데 인스턴스가 다른 인스턴스의 정보가 필요한 이유가 자신이 받은 요청이 다른 인스턴스의 서비스가 필요할 떄가 있어서 그런 건가요??