Skip to content

Instantly share code, notes, and snippets.

View gAmUssA's full-sized avatar
⚡
so hard

Viktor Gamov gAmUssA

⚡
so hard
541 followers · 96 following
View GitHub Profile
@gAmUssA
gAmUssA / test.adoc
Created March 11, 2024 18:30

Hello, Mermaid!

First Section

classDiagram
    class Item {
      <<interface>>
@gAmUssA
gAmUssA / produce.sh
Created February 16, 2024 15:48
#!/bin/bash
# Set the path to your movies.json file
MOVIES_FILE="${MOVIES_FILE:-/app/movies.json}"
# Set the Kafka topic to produce to
KAFKA_TOPIC="${KAFKA_TOPIC:-your_kafka_topic}"
KAFKA_TOPIC_PARTITIONS="${KAFKA_TOPIC_PARTITIONS:-10}"
# Set the Kafka broker address
@gAmUssA
gAmUssA / kuma.yaml
Created May 9, 2023 17:25
---
apiVersion: v1
kind: Namespace
metadata:
name: kuma-system
labels:
kuma.io/system-namespace: "true"
---
apiVersion: v1
@gAmUssA
gAmUssA / service_mesh_for_java_developers_prerequisites.adoc
Last active May 4, 2023 21:50

Workshop: Service Mesh for Java Developers

Requirements for Attendees

To make the most out of the "Service Mesh for Java developers" workshop, attendees are expected to meet the following requirements:

  1. Basic knowledge of Java development: Attendees should be familiar with Java programming concepts and have experience working with Java-based frameworks such as Spring Boot and Micronaut.

  2. Familiarity with containerization:

@gAmUssA
gAmUssA / udp_with_bash.sh
Created October 19, 2021 12:57
#!/bin/bash
exec 3<>/dev/udp/"$1"/"$2"
echo -e "\n" >&3
cat <&3
exit
@gAmUssA
gAmUssA / gp.sh
Created November 2, 2020 16:21 — forked from sunsided/gp.sh
kubectl color output: finally you can tell Pending from Running
# https://unix.stackexchange.com/a/10065
# if stdout is a terminal
if test -t 1; then
# see if it supports colors
ncolors=$(tput colors)
if test -n "$ncolors" && test $ncolors -ge 8; then
bold="$(tput bold)"
underline="$(tput smul)"
standout="$(tput smso)"
normal="$(tput sgr0)"
@gAmUssA
gAmUssA / IqRestApplication.java
Created October 19, 2020 16:48
Kafka Streams interactive questy + Spring webflux
package io.confluent.developer.iqrest;
import org.apache.kafka.common.serialization.Serde;
import org.apache.kafka.common.serialization.Serdes;
import org.apache.kafka.streams.KafkaStreams;
import org.apache.kafka.streams.StoreQueryParameters;
import org.apache.kafka.streams.StreamsBuilder;
import org.apache.kafka.streams.kstream.Consumed;
import org.apache.kafka.streams.kstream.Materialized;
import org.apache.kafka.streams.state.QueryableStoreTypes;
@gAmUssA
gAmUssA / notes.md
Last active May 13, 2020 21:36
5/13 #LiveStreams notes

5/13 #LiveStreams notes

9:47 put link to prep episode

flow

2:06 show starts! 7:52 intro 10:03 NEWS! 10:35 [blog] smarter rebalances in Kafka 12:55 Introducing Meetup Hub

@gAmUssA
gAmUssA / 1.adoc
Created January 21, 2020 16:57
source with ----

Asciidoc code formatting

Example 01

-- SQL Code block
SELECT SOME_FIELD FROM FOO;

Example 02

@gAmUssA
gAmUssA / live_tweeting.sql
Created October 17, 2019 06:37
KSQL code from my NDC Sydney talk
SET 'auto.offset.reset' = 'earliest';
CREATE STREAM twitter_raw ( \
CreatedAt bigint,Id bigint, Text VARCHAR, SOURCE VARCHAR, Truncated VARCHAR, InReplyToStatusId VARCHAR, InReplyToUserId VARCHAR, InReplyToScreenName VARCHAR, GeoLocation VARCHAR, Place VARCHAR, Favorited VARCHAR, Retweeted VARCHAR, FavoriteCount VARCHAR, User VARCHAR, Retweet VARCHAR, Contributors VARCHAR, RetweetCount VARCHAR, RetweetedByMe VARCHAR, CurrentUserRetweetId VARCHAR, PossiblySensitive VARCHAR, Lang VARCHAR, WithheldInCountries VARCHAR, HashtagEntities VARCHAR, UserMentionEntities VARCHAR, MediaEntities VARCHAR, SymbolEntities VARCHAR, URLEntities VARCHAR) \
WITH (KAFKA_TOPIC='twitter_json_01', partitions=12, VALUE_FORMAT='JSON');
CREATE STREAM twitter AS \
SELECT TIMESTAMPTOSTRING(CreatedAt, 'yyyy-MM-dd HH:mm:ss.SSS') AS CreatedAt,\
EXTRACTJSONFIELD(user,'$.Name') AS user_Name, \
EXTRACTJSONFIELD(user,'$.ScreenName') AS user_ScreenName, \