miguno

Live Coding a KSQL Application

Introduction

miguno

// 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

/**
 * @author Danny Miller k2xl@k2xl.com
 */

import java.util.Collection;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;

import backtype.storm.task.OutputCollector;

miguno

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;