Skip to content

Instantly share code, notes, and snippets.

View miguno's full-sized avatar

miguno miguno

874 followers · 3 following
View GitHub Profile
@miguno
miguno / KafkaLocal.java
Created December 20, 2013 13:35 — forked from fjavieralba/KafkaLocal.java
import java.io.IOException;
import java.util.Properties;
import kafka.server.KafkaConfig;
import kafka.server.KafkaServerStartable;
public class KafkaLocal {
public KafkaServerStartable kafka;
public ZooKeeperLocal zookeeper;
@miguno
miguno / gist:9328549
Created March 3, 2014 16:21 — forked from k2xl/gist:1782187
/**
* @author Danny Miller [email protected]
*/
import java.util.Collection;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import backtype.storm.task.OutputCollector;
@miguno
miguno / BinaryToString.java
Last active August 29, 2015 14:06 — forked from codyaray/BinaryToString.java
// Copyright 2014 BrightTag, Inc. All rights reserved.
package com.brighttag.storm.utils;
import backtype.storm.tuple.Values;
import storm.trident.operation.BaseFunction;
import storm.trident.operation.TridentCollector;
import storm.trident.tuple.TridentTuple;
/**
* Converts the first tuple from a byte array into a string.
@miguno
miguno / live-coding-ksql.adoc
Created March 1, 2018 15:24 — forked from rmoff/live-coding-ksql.adoc

Live Coding a KSQL Application

Introduction

@miguno
miguno / interactive-queries_list-app-instances.md
Last active May 14, 2021 15:37 — forked from enothereska/interactive-queries_list-app-instances.md
List all running instances of this application 
# List all running instances of this application
$ http://localhost:7070/kafka-music/instances
[
	{
		"host": "localhost",
 "port": 7070,
@miguno
miguno / interactive-queries_app-instances-for-a-store.md
Created October 31, 2018 16:27 — forked from enothereska/interactive-queries_app-instances-for-a-store.md
List running app instances that currently manage (parts of) state store "top-five-songs" 
# List running app instances that currently manage (parts of) state store "top-five-songs"
$ http://localhost:7070/kafka-music/instances/top-five-songs
[
	{
		"host": "localhost",
 "port": 7070,
@miguno
miguno / interactive-queries_top-five-charts.md
Created October 31, 2018 16:27 — forked from enothereska/interactive-queries_top-five-charts.md
Get the top-5 charts 
# Get all the top-5 charts across all instances
$ http://localhost:7070/kafka-music/charts/top-five
[
  {
    "artist":"Hilltop Hoods",
 "album":"The Calling",
@miguno
miguno / interactive-queries_top-five-charts-genre.md
Created October 31, 2018 16:27 — forked from enothereska/interactive-queries_top-five-charts-genre.md
Get the top-5 charts for genre 'punk' 
# Get all the top-5 charts across all instances
$ http://localhost:7070/kafka-music/charts/genre/punk
[
  {
    "artist":"Wheres The Pope?",
 "album":"PSI",
@miguno
miguno / interactive-queries_song-id.md
Created October 31, 2018 16:27 — forked from enothereska/interactive-queries_song-id.md
Get details for a particular song 
# Get all the top-5 charts across all instances
$ http://localhost:7070/kafka-music/song/9
{
  "artist":"N.W.A",
  "album":"Straight Outta Compton",
 "name":"Gangsta Gangsta"
@miguno
miguno / StreamsDSLAndProcessorExample.java
Last active May 3, 2019 08:54 — forked from confluentgist/StreamsDSLAndProcessorExample.java
/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*