Spring

Spring

• Spring Cloud
• Appendix A. Common application properties

Eureka

• https://www.baeldung.com/spring-cloud-netflix-eureka

BOOT

• Spring Boot Documentation

Data Flow

• Spring Cloud Data Flow
• Spring Cloud Data Flow Reference Guide
• Orchestrating Data Microservices with Spring Cloud Data Flow
• GIT
  • Spring Cloud Data Flow
  • Spring Cloud Data Flow Samples

Cloud Stream APPs Starter

• Spring Cloud Stream App Starters
• OLD REPO, Spring Cloud Stream App Starters

Docker

• Docker compose

Deploy on Kubernetes

• Spring Cloud Data Flow Chart
• Azure Create an internal load balancer

Tasks

• First steps running a Cloud Task on Spring Cloud Data Flow Everyone

apiVersion: v1
kind: Service
metadata:
  name: internal-app
  annotations:
    service.beta.kubernetes.io/azure-load-balancer-internal: "true"
spec:
  type: LoadBalancer
  ports:
  - port: 80
  selector:
    app: internal-app

JAVA DSL

• https://docs.spring.io/spring-cloud-dataflow-samples/docs/current/reference/htmlsingle/
• Deploying a stream programmaticaly
• Python Http Processor

Tasks

Properties

scheduler.kubernetes.entryPointStyle=<Entry Point Style> exec/shell/boot
scheduler.kubernetes.environmentVariables=JAVA_TOOL_OPTIONS=-Xmx1024m
scheduler.kubernetes.imagePullSecret=mysecret
scheduler.kubernetes.entryPointStyle=exec

SHELL

URLS

• https://projects.spring.io/spring-shell/

Example

dataflow:>app import --uri http://bit.ly/Einstein.GA-stream-applications-kafka-10-maven
dataflow:>stream create --name mysqlstream --definition "http --server.port=8787 | jdbc --tableName=names --columns=name --spring.datasource.driver-class-name=org.mariadb.jdbc.Driver --spring.datasource.url='jdbc:mysql://localhost:3306/test'" --deploy
dataflow:>stream list

SKIPPER

• Spring Cloud Skipper Reference Guide

MySql

Clear tasks "running"from queue

delete from TASK_TASK_BATCH;
delete from TASK_EXECUTION_PARAMS;
delete from TASK_EXECUTION;