aditya-suripeddi’s gists

aditya-suripeddi / services.yaml

Last active August 4, 2024 19:43

	# docker compose file for services - DBs, kafka, elastic-search, other services
	# https://gist.github.com/aditya-suripeddi/b1aa9211cf9562d961d0675322ecc74b

	# refer 'Relevant Notes' section below

	version: "3.8"

	services:
	mongo-db:
	image: mongo:7-jammy

aditya-suripeddi / mongo-init.js

Created August 2, 2024 19:41

aditya-suripeddi / ws.scala

Created June 4, 2024 09:52 — forked from adamw/ws.scala

	//> using dep com.softwaremill.sttp.tapir::tapir-netty-server-sync:1.10.7

	import ox.channels.{Actor, ActorRef, Channel, ChannelClosed, Default, DefaultResult, selectOrClosed}
	import ox.{fork, releaseAfterScope, supervised}
	import sttp.tapir.*
	import sttp.tapir.CodecFormat.*
	import sttp.tapir.server.netty.sync.{Id, NettySyncServer, OxStreams}

	import java.util.UUID

aditya-suripeddi / storage.md

Created November 21, 2023 17:03 — forked from debasishg/storage.md

Basics

aditya-suripeddi / application.properties

Created July 1, 2023 12:48 — forked from sangdongvan/application.properties

Config Postgres Datasource for SpringBoot Application

	# ===============================
	# = DATA SOURCE
	# ===============================
	# Set here configurations for the database connection
	spring.datasource.url=jdbc:postgresql://localhost:5432/springbootdb
	spring.datasource.username=postgres
	spring.datasource.password=postgres@123
	spring.datasource.driver-class-name=org.postgresql.Driver
	# Keep the connection alive if idle for a long time (needed in production)
	spring.datasource.testWhileIdle=true

aditya-suripeddi / SimpleKafkaTest.java

Created June 21, 2023 10:13 — forked from vzickner/SimpleKafkaTest.java

Sample Test Case with Embedded Kafka https://blog.mimacom.com/testing-apache-kafka-with-spring-boot-junit5/

	package com.example.demo;

	import org.apache.kafka.clients.consumer.ConsumerRecord;
	import org.apache.kafka.clients.producer.Producer;
	import org.apache.kafka.clients.producer.ProducerRecord;
	import org.apache.kafka.common.serialization.StringDeserializer;
	import org.apache.kafka.common.serialization.StringSerializer;
	import org.junit.jupiter.api.AfterAll;
	import org.junit.jupiter.api.BeforeAll;
	import org.junit.jupiter.api.Test;