| clear query|facets|time |
Search criteria: .
Results from 111 to 120 from
489 (0.168s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[KAFKA-544] Retain key in producer and expose it in the consumer - Kafka - [issue]
|
|
...KAFKA-506 added support for retaining a key in the messages, however this field is not yet set by the producer.The proposal for doing this is to change the producer api to change ProducerDat...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-544
Author: Jay Kreps,
2012-12-04, 23:43
|
|
|
Re: tcp tuning - Kafka - [mail # user]
|
|
...This comes into play in two ways: 1. Sends smaller than the socket send buffer will be asynchronous in 0.7. So if you are using the "sync" setting and are latency sensitive this may be usefu...
|
|
|
Author: Jay Kreps,
2012-11-27, 21:38
|
|
|
Re: understanding partitions based on wiki example of profile visits - Kafka - [mail # dev]
|
|
...We don't have a partition per user, there is no need for that. In the same way a distributed database doesn't have a partition per user. A partition is just a physical grouping of keys. &nbs...
|
|
|
Author: Jay Kreps,
2012-11-27, 21:35
|
|
|
Re: 0.8.0 producer can't connect to cluster? - Kafka - [mail # user]
|
|
...Yeah this was one concern we had in using Yammer--lots of people use it and we would have to agree on versions. On the other hand everyone really wanted it. Not sure if they considered this ...
|
|
|
Author: Jay Kreps,
2012-11-27, 18:30
|
|
|
Re: 0.8.0 producer can't connect to cluster? - Kafka - [mail # user]
|
|
...Yes, we had to patch metrics due to a bug. The patched jar is shipped with the distribution until they get a release out. But logging this in debug is a bug. Would you be willing to fi...
|
|
|
Author: Jay Kreps,
2012-11-27, 18:17
|
|
|
Re: HighwaterMarkCheckpoint - Kafka - [mail # dev]
|
|
...Also I don't see any unit test coverage for this class directly, is that right? If so I will add it... I do see two big integration tests HighwatermarkPersistenceTest and LogRecoveryTe...
|
|
|
Author: Jay Kreps,
2012-11-27, 01:20
|
|
|
Re: HighwaterMarkCheckpoint - Kafka - [mail # dev]
|
|
...Does this capture the intention of this code: https://gist.github.com/4151743 ? The idea is to rename it to OffsetCheckpoint so it is generic. To do this 1. I make the file name and ar...
|
|
|
Author: Jay Kreps,
2012-11-27, 01:17
|
|
|
Re: producer queue size - Kafka - [mail # user]
|
|
...I wonder if this makes sense for the default. I agree that most people who are choosing async would prefer to drop the message rather than block since it is async. But I wonder if we should ...
|
|
|
Author: Jay Kreps,
2012-11-27, 01:02
|
|
|
HighwaterMarkCheckpoint - Kafka - [mail # dev]
|
|
...The api for the HighwaterMarkCheckpoint is: def write(highwaterMarksPerPartition: Map[TopicAndPartition, Long]) def read(topic: String, partition: Int): Long ...
|
|
|
Author: Jay Kreps,
2012-11-27, 00:14
|
|
|
AdminTest is failing on 0.8 - Kafka - [mail # dev]
|
|
...AdminTest.testShutdownBroker is consistently failing since a few checkins ago. I couldn't figure it out but I am pretty sure I didn't cause it... [0m[#27;[31merror#27;[0m] #27;[0mTest ...
|
|
|
Author: Jay Kreps,
2012-11-26, 21:03
|
|
|
|
