Re: Kicking the tires on 0.8.1...tires kicking back

You might be running into the following known bug in 0.8.1: https://issues.apache.org/jira/browse/KAFKA-1310 The fix is to downgrade to 0.8.0, or to migrate to 0.8.1.1 once it gets released (IIRC the tentative 0.8.1.1 release date is mid-April). Best, Michael On 30.03.2014 18:30, Edward Capri

Re: Java API to monitor Consumer Offset and Lag

This SPM: http://sematext.com/spm/ We have classic threshold alerts on this, but also algolertsto detect any sudden anomalies. Otis -- Performance Monitoring * Log Analytics * Search Analytics Solr & Elasticsearc

Re: Kicking the tires on 0.8.1...tires kicking back

The same code works when I switch to 0.8.0 org.apache.kafka kafka_2.9.2 0.8.0 And use my own public static void createTopic(String name, int replica, int partitions ) { String[] arguments =

Kicking the tires on 0.8.1...tires kicking back

I am trying to convert a few projects to the latest kafka... Is this the latest artifact? org.apache.kafka kafka-perf_2.8.0 0.8.1 I have a piece of code @Test public void test() throws InterruptedException { //super.createTopic("

Re: Java API to monitor Consumer Offset and Lag

We have a nagios check that runs the command line lag check and determines if any partition has a lag greater then X. Its about a 2 hour solutiontocode up right but worth every penny. On Fri, Mar 28, 2014 at 7:45 PM, Otis Gospodnetic < otis.gospodne...@gmail.com> wrote: > Hi Harsh, > > Are you t