clear query| facets| time Search criteria: .   Results from 1 to 10 from 1783 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-517] Ensure that we escape the metric names if they include user strings - Kafka - [issue]
...JMX has limits on valid strings. We need to check validity before blindly creating a metric that includes a given topic name. If we fail to do this we will get an exception like this:javax.m...    Author: Jay Kreps , 2018-08-03, 00:29
[KAFKA-3015] Improve JBOD data balancing - Kafka - [issue]
...When running with multiple data directories (i.e. JBOD) we currently place partitions entirely within one data directory. This tends to lead to poor balancing across disks as some topics hav...    Author: Jay Kreps , 2018-08-03, 00:27
[KAFKA-3115] Remove locking in metrics package - Kafka - [issue]
...Currently there is synchronization inside the call  Sensor.record(value)This one lock covers updating all the metrics associated with the Sensor.The nice thing about this is that it mak...    Author: Jay Kreps , 2018-08-02, 22:05
[KAFKA-1696] Kafka should be able to generate Hadoop delegation tokens - Kafka - [issue]
...For access from MapReduce/etc jobs run on behalf of a user....    Author: Jay Kreps , 2018-08-02, 19:59
[KAFKA-658] Implement "Exact Mirroring" functionality in mirror maker - Kafka - [issue]
...There are two ways to implement "mirroring" (i.e. replicating a topic from one cluster to another):1. Do a simple read from the source and write to the destination with no attempt to maintai...    Author: Jay Kreps , 2018-08-02, 19:55
[KAFKA-559] Garbage collect old consumer metadata entries - Kafka - [issue]
...Many use cases involve tranient consumers. These consumers create entries under their consumer group in zk and maintain offsets there as well. There is currently no way to delete these entri...    Author: Jay Kreps , 2018-06-15, 17:16
[KAFKA-1894] Avoid long or infinite blocking in the consumer - Kafka - [issue]
...The new consumer has a lot of loops that look something like  while(!isThingComplete())    client.poll();This occurs both in KafkaConsumer but also in NetworkClient.completeAl...    Author: Jay Kreps , 2018-05-30, 15:34
[KAFKA-1927] Replace requests in kafka.api with requests in org.apache.kafka.common.requests - Kafka - [issue]
...The common package introduced a better way of defining requests using a new protocol definition DSL and also includes wrapper objects for these.We should switch KafkaApis over to use these r...    Author: Jay Kreps , 2018-05-20, 03:28
[expand - 1 more] - [DISCUSS] KIP-263: Allow broker to skip sanity check of inactive segments on broker startup - Kafka - [mail # dev]
...Hey Dong,Makes total sense. What I'm saying is I don't think that the sanity checkis part of any formal guarantee we provide. It is true that corruption ofdata flushed to disk will be a pote...
   Author: Jay Kreps , 2018-03-21, 14:36
[expand - 2 more] - [DISCUSS] KIP-253: Support in-order message delivery with partition expansion - Kafka - [mail # dev]
...Hey Jason,I agree. Even apart from this proposal the partitioning strategy is reallyan essential part of the metadata for a topic and had we been less lazy weprobably would have included it ...
   Author: Jay Kreps , 2018-03-07, 22:05