public void test() {
> Producer producer = new Producer(config);
> KeyedMessage data = new KeyedMessage String>("H406", "test", "test");
> }
>
> What am I missing?
>
>
>
>
> From: Joe Stein
> To: "
fig);
> KeyedMessage data = new KeyedMessage String>("H406", "test", "test");
> }
>
> What am I missing?
>
>
>
>
> From: Joe Stein
> To: "users@kafka.apache.org"
> Sent: Tuesday, A
a.apache.org"
Sent: Tuesday, August 27, 2013 3:31 PM
Subject: Re: Help getting started
You can use the binary distribution if you like
https://dist.apache.org/repos/dist/release/kafka/kafka_2.8.0-0.8.0-beta1.tgz
As far as what is causing the error will need more info can you maybe take
e
Runner.runTests(RemoteTestRunner.java:683)
> at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390)
> at
> org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197)
>
>
>
> ____
> From: Joe Stein
> To: us
)
From: Joe Stein
To: users@kafka.apache.org; Robert Heise
Sent: Tuesday, August 27, 2013 2:40 PM
Subject: Re: Help getting started
Hey Robert, the latest quick start is here
http://kafka.apache.org/documentation.html#quickstart
Can you give that a try please, thanks
Hey Robert, the latest quick start is here
http://kafka.apache.org/documentation.html#quickstart
Can you give that a try please, thanks!
/***
Joe Stein
Founder, Principal Consultant
Big Data Open Source Security LLC
http://www.stealth.ly
Twitter: @allt