JulieOpsでKafkaTopicを宣言的に管理する

KafkaにCLIでProduce/Consumeするときはkcatが便利

KafkaConnectでS3のデータを扱う

DatagenSourceConnectorでAvroスキーマをもとにダミーデータを生成する

ConsumerGroupIDはいつまで保持されるのか

JDBCSourceConnectorのDBセッションをどう切断するか

confluent-kafka-goで指定できるクライアント側のパラメーター

1つのトピックで複数のイベントを扱う

ksqlDBでUNION(ALL)したかった

ConsumerGroup単位でのConsumerLagをPrometheusに連携したい

kafka-producer-perf-testを使う時に気を付けていること

KafkaClusterIDを調べる

KafkaConnectでSourceConnectorのオフセットをリセットする

KafkaのQuotaにデフォルト値を設定したい

KafkaConnectのDLQに入ったメッセージをどうリカバリするか

kafka-console-consumerで__consumer_offsetsを読み取る

JDBCSourceConnectorで特定のトピックにデータを連携する

KafkaTopic名の長さ

ボトルネックがクライアント側にあるのかブローカー側にあるのかを簡易的に切り分ける

kafka-consumer-perf-testの--threadもDepricatedになってる