noslowerdna

package com.cerner.common.kafka.consumer.assignors;

import org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor;
import org.apache.kafka.common.TopicPartition;
import org.apache.kafka.common.utils.Utils;

import java.util.ArrayList;
import java.util.Comparator;
import java.util.Collections;
import java.util.HashMap;

noslowerdna

A
B
C
D
E
F
G
H
AB
AC

noslowerdna

A
B
C
AB
AC
BC
AAB
AAC
ABB
ABC

noslowerdna

require 'set'
require 'prime'

letters = 3
max_word_length = 5

alphabet = (0...letters).collect { |i| ('A'.ord + i).chr }
all_words = SortedSet.new

for i in 1..max_word_length

noslowerdna

import com.yammer.metrics.Metrics;
import com.yammer.metrics.core.Counter;
import com.yammer.metrics.core.Meter;
import com.yammer.metrics.core.Timer;
import com.yammer.metrics.core.TimerContext;
import com.yammer.metrics.web.WebappMetricsFilter;

import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;

noslowerdna

Status

Current state: Under Discussion

Discussion thread:

JIRA:

• KAFKA-2435
• KAFKA-3297

noslowerdna

diff --git a/project/Project.scala b/project/Project.scala
index 39f4ddd..d925db4 100644
--- a/project/Project.scala
+++ b/project/Project.scala
@@ -181,7 +181,7 @@ object Zipkin extends Build {
   ).settings(
     libraryDependencies ++= Seq(
       "play" %% "anorm" % "2.1-09142012",
-      "org.apache.commons" % "commons-dbcp2" % "2.1",
+      "com.zaxxer" % "HikariCP-java6" % "2.3.8",

noslowerdna

import static org.apache.hadoop.hbase.util.Bytes.toBytes;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseTestingUtility;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.KeyValue;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;