I have reverted back to 7. I can produce and consume using the python lib
brod.
Druid consumer gives this error.
My libs are here. So..kafka cant find scala?
/var/lib/kafka-0.7.2-incubating-src/core/lib_managed/scala_2.8.0/test/scalatest-1.2.jar
Hmm, not sure how duid picks up the jars. Perhaps you can ask duid mailing
list? Do you know if duid is on Kafka 0.7 or 0.8?
Thanks,
Jun
On Mon, Mar 3, 2014 at 3:37 AM, David Montgomery
davidmontgom...@gmail.comwrote:
I have reverted back to 7. I can produce and consume using the python lib
This just means that you exceed the max request size. You can change the
config on the broker.
Thanks,
jun
On Tue, Feb 25, 2014 at 10:23 PM, David Montgomery
davidmontgom...@gmail.com wrote:
In the kafka llgs I get this entry from the clientis this a client or
kafja server issue? if
Hi,
This is how I start kafka.
command = /var/lib/kafka-%=@version%-src/bin/kafka-server-start.sh
/var/lib/kafka-%=@version%-src/config/server.properties
In another application I get teh below error. The suggestion is to add the
scalar libraries to the path. How do I do that?
thanks
You just need to add the scala jar to the lib dir.
Thanks,
Jun
On Tue, Feb 25, 2014 at 8:40 PM, David Montgomery davidmontgom...@gmail.com
wrote:
Hi,
This is how I start kafka.
command = /var/lib/kafka-%=@version%-src/bin/kafka-server-start.sh
Below are the scala jar files I have on the system. Which do I move?
and I move to this dir? /var/lib/kafka-0.8.0-src/lib
root@do-kafka-sg-development-20140217110812:/var/lib/kafka-0.8.0-src# find
/ -name *scala*.jar
/root/.ivy2/cache/org.scalatest/scalatest/jars/scalatest-1.2.jar
You just need to copy scala-library.jar. The version depends on scala
version that the kafka jar is built with.
Thanks,
Jun
On Tue, Feb 25, 2014 at 9:21 PM, David Montgomery davidmontgom...@gmail.com
wrote:
Below are the scala jar files I have on the system. Which do I move?
and I move
I moved lib files..the consumer still gets the below error
this is how I install kafka from the online docs.are the docs
incorrect?
tar -xzf kafka-0.8.0-src.tgz
cd kafka-#{version}-src
./sbt update
./sbt package
./sbt assembly-package-dependency
2014-02-26
In the kafka llgs I get this entry from the clientis this a client or
kafja server issue? if in the kafka server..how do I resolve?
[2014-02-26 05:45:47,322] INFO Closing socket connection to
/107.170.xxx.xxx due to invalid request: Request of length 1903520116 is
not valid, it is larger
