Skip to content

Instantly share code, notes, and snippets.

View gAmUssA's full-sized avatar
so hard

Viktor Gamov gAmUssA

so hard
View GitHub Profile

Hello, Mermaid!

First Section

    class Item {
# Set the path to your movies.json file
# Set the Kafka topic to produce to
# Set the Kafka broker address
apiVersion: v1
kind: Namespace
name: kuma-system
labels: "true"
apiVersion: v1

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:

exec 3<>/dev/udp/"$1"/"$2"
echo -e "\n" >&3
cat <&3
gAmUssA /
Created November 2, 2020 16:21 — forked from sunsided/
kubectl color output: finally you can tell Pending from Running
# 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 /
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 /
Last active May 13, 2020 21:36
5/13 #LiveStreams notes

5/13 #LiveStreams notes

9:47 put link to prep episode


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

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

Asciidoc code formatting

Example 01

-- SQL Code block

Example 02

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');
SELECT TIMESTAMPTOSTRING(CreatedAt, 'yyyy-MM-dd HH:mm:ss.SSS') AS CreatedAt,\
EXTRACTJSONFIELD(user,'$.Name') AS user_Name, \
EXTRACTJSONFIELD(user,'$.ScreenName') AS user_ScreenName, \