| clear query|facets|time |
Search criteria: .
Results from 51 to 60 from
120 (0.052s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Troubles with compressed message set - Kafka - [mail # dev]
|
|
...On 1/30/13 11:18 AM, Jay Kreps wrote:> Hi David,>> MessageSets aren't size delimited because that format is shared with> producer/consumer and the kafka log itself. The log itsel...
|
|
|
Author: David Arthur,
2013-01-30, 21:07
|
|
|
Re: Troubles with compressed message set - Kafka - [mail # dev]
|
|
...Jay,Figured it out.In Message.scala, CurrentMagicValue is set to 0; should be 2. This was causing my client to attempt to decode it as a v0 message. Changing the value to 2 solved my problem...
|
|
|
Author: David Arthur,
2013-01-30, 21:00
|
|
|
Troubles with compressed message set - Kafka - [mail # dev]
|
|
...I'm working on a client and I'm running into difficulties with compressed message sets. I am able to produce them fine, but when I go to fetch them, things seem strange.I am sending a messag...
|
|
|
Author: David Arthur,
2013-01-30, 15:27
|
|
|
Re: Question about offsets - Kafka - [mail # dev]
|
|
...Thanks, Jay. Makes sense+1 for documentation. I think in general the wiki is a bit unorganized, makes it hard to know what is the "current" info vs old proposals.-DavidOn 1/30/13 12:01 AM, J...
|
|
|
Author: David Arthur,
2013-01-30, 13:54
|
|
|
Question about offsets - Kafka - [mail # dev]
|
|
...Fiddling with my Python client on 0.8, noticed something has changed with offsets.It seems that instead of a byte offset in the log file, the offset is now a logical one. I had a few questio...
|
|
|
Author: David Arthur,
2013-01-30, 04:39
|
|
|
Re: Difficulties packaging trunk - Kafka - [mail # dev]
|
|
...Turns out I was using a ZK chroot in my server.properties and the znode didn't exist, so kafka.Kafka was returning right away. Strange that there was no error message though.On 1/27/13 9:54 ...
|
|
|
Author: David Arthur,
2013-01-27, 15:55
|
|
|
Difficulties packaging trunk - Kafka - [mail # dev]
|
|
...I'm trying to run the latest trunk code.I'm packaging the project as indicated by the README > ./sbt "+package"which runs fine, but then I try to run ./bin/kafka-server-start.sh, I g...
|
|
|
Author: David Arthur,
2013-01-27, 14:54
|
|
|
KafkaStream, ConsumerConnector, and 0.8 - Kafka - [mail # dev]
|
|
...By centralizing offset management (with the new Commit/FetchOffsets APIs), consuming is now much simpler and no longer relies on clients connecting directly to ZooKeeper.As such, I'm wonderi...
|
|
|
Author: David Arthur,
2013-01-22, 15:51
|
|
|
[KAFKA-689] Can't append to a topic/partition that does not already exist - Kafka - [issue]
|
|
...With a totally fresh Kafka (empty logs dir and empty ZK), if I send a ProduceRequest for a new topic, Kafka responds with "kafka.common.UnknownTopicOrPartitionException: Topic test part...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-689
Author: David Arthur,
2013-01-10, 18:40
|
|
|
[KAFKA-690] TopicMetadataRequest throws exception when no topics are specified - Kafka - [issue]
|
|
...If no topics are sent in a TopicMetadataRequest, `readFrom` throws an exception when trying to get the the head of the topic list for a debug statement.java.util.NoSuchElementException: head...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-690
Author: David Arthur,
2013-01-09, 16:49
|
|
|
|
