Lab 8022 - EventMesh - TEQ / KAFKA : Repo Migration (#306)

* On branch pasimoes/lab-8022/repo-migration
 Changes to be committed: migrating all project from oracle-db-examples repo to dcms repo.
 Target: /microservices-datadriven/workshops/eventmesh-teq-kafka

* add workshop spefic reqs in root .gitignore and remove prj .gitignore

Author: pasimoes

.gitignore

@@ -481,3 +481,23 @@ $RECYCLE.BIN/
 #!.vscode/tasks.json
 #!.vscode/launch.json
 #!.vscode/extensions.json
+
+##
+## Gradle
+##
+.gradle/
+.gradle/*
+
+## Workshops / Event Mesh - TEQ - Kafka 
+##
+## Local JVM
+##
+workshops/eventmesh-teq-kafka/.java-version
+
+## Remove Deploy Dir -- K8s Deployment artifacts
+workshops/eventmesh-teq-kafka/**/deploy/
+
+## Remove Other Local project stuffs
+workshops/eventmesh-teq-kafka/cloud-setup/database/
+workshops/eventmesh-teq-kafka/cloud-setup/terraform_dbsystem/
+workshops/eventmesh-teq-kafka/wallet/

workshops/eventmesh-teq-kafka/LICENSE.txt

@@ -0,0 +1,35 @@
+ Copyright (c) 2021 Oracle and/or its affiliates.
+
+ The Universal Permissive License (UPL), Version 1.0
+
+ Subject to the condition set forth below, permission is hereby granted to any
+ person obtaining a copy of this software, associated documentation and/or data
+ (collectively the "Software"), free of charge and under any and all copyright
+ rights in the Software, and any and all patent rights owned or freely
+ licensable by each licensor hereunder covering either (i) the unmodified
+ Software as contributed to or provided by such licensor, or (ii) the Larger
+ Works (as defined below), to deal in both
+ 
+ (a) the Software, and
+ (b) any piece of software and/or hardware listed in the lrgrwrks.txt file if
+ one is included with the Software (each a "Larger Work" to which the Software
+ is contributed by such licensors),
+ 
+ without restriction, including without limitation the rights to copy, create
+ derivative works of, display, perform, and distribute the Software and make,
+ use, sell, offer for sale, import, export, have made, and have sold the
+ Software and the Larger Work(s), and to sublicense the foregoing rights on
+ either these or other terms.
+ 
+ This license is subject to the following condition:
+ The above copyright notice and either this complete permission notice or at
+ a minimum a reference to the UPL must be included in all copies or
+ substantial portions of the Software.
+ 
+ THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+ SOFTWARE.

workshops/eventmesh-teq-kafka/cloud-setup/confluent-kafka/docker-compose.yml

@@ -0,0 +1,33 @@
+---
+version: '3'
+services:
+  zookeeper:
+    image: confluentinc/cp-zookeeper:7.0.1
+    container_name: zookeeper
+    environment:
+      ZOOKEEPER_CLIENT_PORT: 2181
+      ZOOKEEPER_TICK_TIME: 2000
+
+  broker:
+    image: confluentinc/cp-kafka:7.0.1
+    container_name: broker
+    ports:
+      # To learn about configuring Kafka for access across networks see
+      # https://www.confluent.io/blog/kafka-client-cannot-connect-to-broker-on-aws-on-docker-etc/
+      - "9092:9092"
+    depends_on:
+      - zookeeper
+    environment:
+      KAFKA_BROKER_ID: 1
+      KAFKA_ZOOKEEPER_CONNECT: 'zookeeper:2181'
+      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_INTERNAL:PLAINTEXT
+      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092,PLAINTEXT_INTERNAL://broker:29092
+      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
+      KAFKA_TRANSACTION_STATE_LOG_MIN_ISR: 1
+      KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR: 1
+
+      ## Update from 6.2.0 to 7.0.1
+      ## December 2021 Log4j Vulnerabilities Advisory
+      ## https://support.confluent.io/hc/en-us/articles/4412615410580-December-2021-Log4j-Vulnerabilities-Advisory
+      ## Security Release Notes for CP 7.0.1
+      ## https://support.confluent.io/hc/en-us/articles/4412607023124-Security-Release-Notes-for-CP-7-0-1

workshops/eventmesh-teq-kafka/cloud-setup/destroy.sh

@@ -0,0 +1,13 @@
+#!/bin/bash
+# Copyright (c) 2021 Oracle and/or its affiliates.
+# Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
+
+# Make sure this is run via source or .
+if ! (return 0 2>/dev/null); then
+  echo "ERROR: Usage 'source destroy.sh'"
+  exit
+fi
+
+"$LAB_HOME"/cloud-setup/utils/main-destroy.sh
+
+cd

workshops/eventmesh-teq-kafka/cloud-setup/env.sh

@@ -0,0 +1,56 @@
+#!/bin/bash
+# Copyright (c) 2021 Oracle and/or its affiliates.
+# Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
+
+# Make sure this is run via source or .
+if ! (return 0 2>/dev/null); then
+  echo "ERROR: Usage 'source env.sh'"
+  exit
+fi
+
+# POSIX compliant find and replace
+function sed_i(){
+  local OP="$1"
+  local FILE="$2"
+  sed -e "$OP" "$FILE" >"/tmp/$FILE"
+  mv -- "/tmp/$FILE" "$FILE"
+}
+export -f sed_i
+
+# Set LAB_HOME
+str="$( cd "$( dirname "${BASH_SOURCE[0]}" )" &> /dev/null && pwd )"
+substr="cloud-setup"
+prefix=${str%%$substr*}
+index=${#prefix}
+export LAB_HOME=${str:0:$index-1}
+
+# export LAB_HOME="$( cd "$( dirname "${BASH_SOURCE[0]}" )" &> /dev/null && pwd )"
+# shellcheck disable=SC2164
+cd "$LAB_HOME"
+echo "LAB_HOME: $LAB_HOME"
+
+# Java Home
+if test -d ~/graalvm-ce-java11-21.3.0/Contents/Home/bin; then
+  # We are on Mac doing local dev
+  export JAVA_HOME=~/graalvm-ce-java11-21.3.0/Contents/Home;
+else
+  # Assume linux
+  export JAVA_HOME=~/graalvm-ce-java11-21.3.0
+fi
+export PATH=$JAVA_HOME/bin:$PATH
+
+# State directory
+if test -d ~/lab-state; then
+  export LAB_STATE_HOME=~/lab-state
+else
+  export LAB_STATE_HOME="${LAB_HOME}"/cloud-setup/state
+fi
+
+# Log directory
+export LAB_LOG="${LAB_HOME}"/cloud-setup/log
+mkdir -p "${LAB_LOG}"
+
+# Source the state functions
+source "${LAB_HOME}"/cloud-setup/utils/state-functions.sh
+
+export PATH=$PATH:${LAB_HOME}/cloud-setup/utils/

workshops/eventmesh-teq-kafka/cloud-setup/setup.sh

@@ -0,0 +1,21 @@
+#!/bin/bash
+# Copyright (c) 2021 Oracle and/or its affiliates.
+# Licensed under the Universal Permissive License v 1.0 as shown at https://oss.oracle.com/licenses/upl.
+
+# Make sure this is run via source or .
+if ! (return 0 2>/dev/null); then
+  echo "ERROR: Usage 'source setup.sh'"
+  exit
+fi
+
+if state_done SETUP; then
+  echo "The setup has been completed"
+  return
+fi
+
+SETUP_SCRIPT="$LAB_HOME/cloud-setup/utils/main-setup.sh"
+if ps -ef | grep "$SETUP_SCRIPT" | grep -v grep; then
+  echo "The $SETUP_SCRIPT is already running.  If you want to restart it then kill it and then rerun."
+else
+  $SETUP_SCRIPT 2>&1 | tee -ai "$LAB_LOG"/main-setup.log
+fi

workshops/eventmesh-teq-kafka/cloud-setup/terraform_atp/oci_atp_datasources.tf

@@ -0,0 +1,22 @@
+// Copyright (c) 2017, 2021, Oracle and/or its affiliates. All rights reserved.
+// Licensed under the Mozilla Public License v2.0
+
+data "oci_identity_availability_domain" "ad1" {
+  compartment_id = var.tenancy_ocid
+  ad_number      = 1
+}
+
+data "oci_database_autonomous_databases" "autonomous_databases_atp" {
+  #Required
+  compartment_id = var.compartment_ocid
+
+  #Optional
+  display_name = var.autonomous_database_display_name
+  db_workload  = var.autonomous_database_db_workload
+}
+
+//======= Name space details ------------------------------------------------------
+data "oci_objectstorage_namespace" "lab8022_objstore_namespace" {
+  #Optional
+  compartment_id = var.compartment_ocid
+}

workshops/eventmesh-teq-kafka/cloud-setup/terraform_atp/oci_atp_outputs.tf

@@ -0,0 +1,11 @@
+// Copyright (c) 2017, 2021, Oracle and/or its affiliates. All rights reserved.
+// Licensed under the Mozilla Public License v2.0
+
+//========= Outputs ===========================
+output "ns_objectstorage_namespace" {
+    value =  [ data.oci_objectstorage_namespace.lab8022_objstore_namespace.namespace ]
+}
+
+output "autonomous_database_admin_password" {
+    value =  [ "Welcome12345" ]
+}

workshops/eventmesh-teq-kafka/cloud-setup/terraform_atp/oci_atp_resources.tf

@@ -0,0 +1,35 @@
+//================= create ATP Instance =======================================
+resource "random_string" "autonomous_database_wallet_password" {
+  length  = 16
+  special = true
+}
+resource "random_password" "database_admin_password" {
+  length  = 12
+  upper   = true
+  lower   = true
+  number  = true
+  special = false
+  min_lower = "1"
+  min_upper = "1"
+  min_numeric = "1"
+}
+resource "oci_database_autonomous_database" "autonomous_database_atp" {
+  #Required
+  compartment_id           = var.compartment_ocid
+  db_name                  = var.autonomous_database_db_name
+
+  #Optional
+  admin_password           = random_password.database_admin_password.result
+  cpu_core_count           = var.autonomous_database_cpu_core_count
+  data_storage_size_in_tbs = var.autonomous_database_data_storage_size_in_tbs
+  # is_free_tier = true , if there exists sufficient service limit
+  is_free_tier             = var.autonomous_database_is_free_tier
+  db_workload              = var.autonomous_database_db_workload
+  db_version               = var.autonomous_database_db_version
+  license_model            = var.autonomous_database_license_model
+  display_name             = var.autonomous_database_display_name
+  is_auto_scaling_enabled                        = "false"
+  is_preview_version_with_service_terms_accepted = "false"
+}
+
+

workshops/eventmesh-teq-kafka/cloud-setup/terraform_atp/oci_atp_variables.tf

@@ -0,0 +1,53 @@
+// Copyright (c) 2017, 2021, Oracle and/or its affiliates. All rights reserved.
+// Licensed under the Mozilla Public License v2.0
+
+variable "tenancy_ocid" { }
+variable "user_ocid" { }
+variable "region" { }
+variable "compartment_ocid" { }
+
+variable "autonomous_database_db_workload" {
+  default = "OLTP"
+}
+
+variable "autonomous_database_defined_tags_value" {
+  default = "value"
+}
+
+variable "autonomous_database_license_model" {
+  default = "BRING_YOUR_OWN_LICENSE"
+}
+
+variable "autonomous_database_is_dedicated" {
+  default = false
+}
+
+variable "autonomous_database_cpu_core_count" {
+  default = "2"
+}
+
+variable "autonomous_database_db_name" {
+  default = "atp_db1"
+}
+
+variable "autonomous_database_db_version" {
+  description = "Oracle Autonomous Database Version"
+  type = string
+  default = "19c"
+  validation {
+    condition     = contains(["19c", "21c"], var.autonomous_database_db_version)
+    error_message = "Valid values for var: autonomous_database_db_version are (19c, 21c)."
+  }
+}
+
+variable "autonomous_database_display_name" {
+  default = "MyATPDB"
+}
+
+variable "autonomous_database_data_storage_size_in_tbs" {
+  default = "1"
+}
+
+variable "autonomous_database_is_free_tier" {
+  default = false
+}