dunithd

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

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

{
  "openapi": "3.0.0",
  "info": {
    "version": "1.0.0",
    "title": "OrderConfirmed"
  },
  "paths": {},
  "components": {
    "schemas": {
      "AWSEvent": {

dunithd

@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

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

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

{
    "schemaName": "steps",
    "dimensionFieldSpecs": [
      {
        "name": "userId",
        "dataType": "INT"
      },
      {
        "name": "userName",
        "dataType": "STRING"

dunithd

{
    "tableName": "steps",
    "tableType": "REALTIME",
    "segmentsConfig": {
      "timeColumnName": "loggedAt",
      "timeType": "MILLISECONDS",
      "schemaName": "steps",
      "replicasPerPartition": "1"
    },
    "tenants": {},

dunithd

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

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",