mhowlett

---
version: '2'
services:
  zk1:
    image: confluentinc/cp-zookeeper:3.0.1
    ports: 
      - "22181:22181"
    environment:
      ZOOKEEPER_SERVER_ID: 1
      ZOOKEEPER_CLIENT_PORT: 22181

mhowlett

package main

import (
	"context"
	"flag"
	"math/rand"
	crand "crypto/rand"
	"os"
	"time"
	"log"

mhowlett

{
  "type": "record",
  "name": "UpdatedTable",
  "namespace": "io.confluent.test",
  "fields": [
    {
      "name": "source",
      "type": [
        "null",
        {

mhowlett

{
  "type": "record",
  "name": "SomeTable",
  "namespace": "com.company.name",
  "fields": [
    {
      "name": "aname",
      "type": [
        "null",
        {

mhowlett

// docker run -d -p 8080:8080 -v /git/myproj:/tmp/here wernight/phantomjs phantomjs /tmp/here/renderpage.js

var system = require('system');
var fs = require('fs');
var webserver = require('webserver');
var args = system.args;

var page = require('webpage').create();

phantom.onError = function(msg, trace) {

mhowlett

class Program
    {
        static void Main(string[] args)
        {
            var config = new Dictionary<string, object>
            {
                { "bootstrap.servers", "10.200.7.144:9092" }
            };

            var bigNumber = 100;

mhowlett

using System;
using System.Text;
using System.Collections.Generic;
using Confluent.Kafka;
using Confluent.Kafka.Serialization;


namespace Issue470
{
    class Program

mhowlett

#!/usr/local/bin/python

with open ("/git/confluent-kafka-dotnet/src/Confluent.Kafka/project.json", "r") as myfile:
        data = myfile.readlines()

out = []
for line in data:
        line2 = line[:-1]
        if "net451" in line2:
                if line2[0:2] == "/*":

mhowlett

{
    "version": "0.2.0",
    "configurations": [
        {
            "name": "SimpleProducer",
            "type": "coreclr",
            "request": "launch",
            "preLaunchTask": "build",
            "program": "${workspaceRoot}/examples/SimpleProducer/bin/Debug/netcoreapp1.0/SimpleProducer.dll",
            "args": ["localhost:9092", "mytt"],

mhowlett

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using RdKafka;

namespace AdvancedConsumer
{
    public class Program
    {