Dunith Dhanushka dunithd
dunithd
/ EventProducer.java
Last active
March 10, 2021 04:16
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.edu.eb; | |
| import schema.edu_orders.orderconfirmed.AWSEvent; | |
| import schema.edu_orders.orderconfirmed.Customer; | |
| import schema.edu_orders.orderconfirmed.Item; | |
| import schema.edu_orders.orderconfirmed.OrderConfirmed; | |
| import schema.edu_orders.orderconfirmed.marshaller.Marshaller; | |
| import software.amazon.awssdk.regions.Region; | |
| import software.amazon.awssdk.services.eventbridge.EventBridgeClient; | |
| import software.amazon.awssdk.services.eventbridge.model.*; |
dunithd
/ EmailSender.java
Created
March 10, 2021 04:18
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.edu.eb; | |
| import java.io.IOException; | |
| import java.io.InputStream; | |
| import java.io.OutputStream; | |
| import com.amazonaws.services.lambda.runtime.Context; | |
| import com.amazonaws.services.lambda.runtime.RequestStreamHandler; | |
| import schema.edu_orders.orderconfirmed.AWSEvent; | |
| import schema.edu_orders.orderconfirmed.OrderConfirmed; |
dunithd
/ edu.orders@OrderConfirmed.json
Created
March 10, 2021 04:31
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "openapi": "3.0.0", | |
| "info": { | |
| "version": "1.0.0", | |
| "title": "OrderConfirmed" | |
| }, | |
| "paths": {}, | |
| "components": { | |
| "schemas": { | |
| "AWSEvent": { |
dunithd
/ credit-limit-alert.sql
Created
June 11, 2021 18:18
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| @App:name("CreditLimitReaching") | |
| @App:description("Description of the plan") | |
| @Store(type="rdbms", | |
| jdbc.url="jdbc:mysql://localhost:3306/foobank?useSSL=false", | |
| username="root", | |
| password="*****" , | |
| jdbc.driver.name="com.mysql.jdbc.Driver") | |
| @PrimaryKey("id") |
dunithd
/ ConsumedMessage.java
Created
July 25, 2021 15:42
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.edu.samples.messagelog; | |
| import javax.persistence.Entity; | |
| import javax.persistence.Id; | |
| import javax.persistence.Table; | |
| import java.time.Instant; | |
| @Entity | |
| @Table(name = "consumed_messages") | |
| public class ConsumedMessage { |
dunithd
/ OrderEventHandler.java
Created
July 25, 2021 15:44
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package com.edu.samples; | |
| import com.edu.samples.messagelog.MessageLog; | |
| import com.edu.samples.serde.OrderEvent; | |
| import org.slf4j.Logger; | |
| import org.slf4j.LoggerFactory; | |
| import javax.enterprise.context.ApplicationScoped; | |
| import javax.inject.Inject; | |
| import javax.transaction.Transactional; |
dunithd
/ steps-schema.json
Created
July 31, 2021 18:49
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "schemaName": "steps", | |
| "dimensionFieldSpecs": [ | |
| { | |
| "name": "userId", | |
| "dataType": "INT" | |
| }, | |
| { | |
| "name": "userName", | |
| "dataType": "STRING" |
dunithd
/ steps-table.json
Created
July 31, 2021 18:51
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| { | |
| "tableName": "steps", | |
| "tableType": "REALTIME", | |
| "segmentsConfig": { | |
| "timeColumnName": "loggedAt", | |
| "timeType": "MILLISECONDS", | |
| "schemaName": "steps", | |
| "replicasPerPartition": "1" | |
| }, | |
| "tenants": {}, |
dunithd
/ docker-compose-postgres+debezium.yml
Created
August 10, 2021 09:17
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| version: "3.7" | |
| services: | |
| postgres: | |
| image: debezium/postgres:13 | |
| ports: | |
| - 5432:5432 | |
| healthcheck: | |
| test: "pg_isready -U postgresuser -d shipment_db" | |
| interval: 2s | |
| timeout: 20s |
dunithd
/ create-postgres-debezium-connector.sh
Created
August 10, 2021 09:18
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| curl -H 'Content-Type: application/json' debezium:8083/connectors --data ' | |
| { | |
| "name": "shipments-connector", | |
| "config": { | |
| "connector.class": "io.debezium.connector.postgresql.PostgresConnector", | |
| "plugin.name": "pgoutput", | |
| "database.hostname": "postgres", | |
| "database.port": "5432", | |
| "database.user": "postgresuser", | |
| "database.password": "postgrespw", |