Skip to content

Instantly share code, notes, and snippets.

/*
* This file was generated by the Gradle 'init' task.
*
* This generated file contains a sample Kotlin application project to get you started.
* For more details take a look at the 'Building Java & JVM projects' chapter in the Gradle
* User Manual available at https://docs.gradle.org/7.2/userguide/building_java_projects.html
*/
plugins {
// Apply the org.jetbrains.kotlin.jvm Plugin to add support for Kotlin.

Kafka Producerを実装する

この文書で達成されること

  • Kotlinを使って単純なテキストを受け取って送信するKafka Producerを実装する

ビルド環境

Gradle

Kafka Consumerを実装する

この文書で達成されること

  • Kotlinを使って単純なテキストを受け取って出力するKafka Consumerを実装する

ビルド環境

Gradle

Kafka 実行環境構築 (not docker, not k8s)

書いた経緯

遊びで使っている、MacBook Air (M1, 2020) メモリ 8GBの環境でKafkaを使ったアプリケーションを作ろうとしていた。 Kafka環境構築のために、当初はk8sを使おうとしていたのだが、メモリ不足で立ち上げることができなかった。 次にdocker composeを利用することも考えたが、興味の対象はKafkaの運用ではなく、Kafkaで実行されるアプリケーションにあったので、とりあえずOSX上で直接Kafkaを動かすことにした。 あくまで開発用のため、レプリケーションの設定も含めて適当である。

この文書で達成されること

# How to run Kafka using helm
2021-09-02
## Prerequisite
- local kubernetes cluster
- helm
- https://helm.sh/docs/intro/install/
/*
package dynamodb
import com.amazonaws.services.dynamodbv2.local.embedded.DynamoDBEmbedded
import com.amazonaws.services.dynamodbv2.model.*
import software.amazon.awssdk.services.dynamodb.model.GetItemRequest
import software.amazon.awssdk.services.dynamodb.model.AttributeValue
import software.amazon.awssdk.enhanced.dynamodb.DynamoDbEnhancedClient
import kotlin.test.Test
@kmtr
kmtr / gist:1380970
Last active July 18, 2019 21:42
smiley prompt($PS1)
(・ᴗ・):\w\n$
ʕ ◔ϖ◔ʔ:\w\n$
# using docker https://github.com/Ragnaroek/rust-on-raspberry-docker
#
# requirement
# - cargo (this Makefile for a cargo project)
# - docker
# - jq (for getting metadata of a project)
# - scp (for deploying)
IMAGE_VERSION=1.18.0
PROJECT_NAME = $(shell cargo metadata --format-version=1 --no-deps | jq -r .packages[0].name)
package main
import (
"context"
"fmt"
"log"
"os"
"os/exec"
"strings"
"sync"
[[plugins]]
repo = 'Shougo/dein.vim'
[[plugins]] # Japanese doc
repo = 'vim-jp/vimdoc-ja'
hook_add = '''
set helplang=ja,en
'''
[[plugins]]