Edward J. Yoon
Arun C Murthy
Vinod Kumar Vavilapalli
Jarek Jarcec Cecho
mail # dev
mail # user
last 7 days (3)
last 30 days (6)
last 90 days (13)
last 6 months (30)
last 9 months (1749)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[KAFKA-517] Ensure that we escape the metric names if they include user strings
...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...
, 2017-11-17, 14:38
[KAFKA-414] Evaluate mmap-based writes for Log implementation
...Working on another project I noticed that small write performance for FileChannel is really very bad. This likely effects Kafka in the case where messages are produced one at a time or in sm...
, 2017-11-16, 16:45
[KAFKA-506] Store logical offset in log
...Currently we only support retention by dropping entire segment files. A more nuanced retention policy would allow dropping individual messages from a segment file by recopying it. This is no...
, 2017-11-16, 10:04
[KAFKA-1895] Investigate moving deserialization and decompression out of KafkaConsumer
...The consumer implementation in KAFKA-1760 decompresses fetch responses and deserializes them into ConsumerRecords which are then handed back as the result of poll().There are several downsid...
, 2017-11-06, 17:41
[KAFKA-1894] Avoid long or infinite blocking in the consumer
...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...
, 2017-11-06, 17:41
[KAFKA-610] connect.timeout.ms seems to do the wrong thing in the producer
...This setting used to control the socket connection timeout. This is also what the documentation says:"the maximum time spent by kafka.producer.SyncProducer trying to connect to the kafka bro...
, 2017-10-30, 12:23
The idea of "composite key" to make log compaction more flexible - question / proposal
- [mail # user]
...I think you can do this now by using a custom partitioner, no?https://kafka.apache.org/0110/javadoc/org/apache/kafka/clients/producer/Partitioner.html-JayOn Mon, Oct 2, 2017 at 6:29 AM Micha...
, 2017-10-05, 14:22
[DISCUSS] URIs on Producer and Consumer
- [mail # dev]
...Hey Clebert,Is there a motivation for adding a second way? We generally try to avoidhaving two ways to do something unless it's really needed...I suspect youhave a reason for wanting this, t...
, 2017-10-05, 14:15
How is CorrelationId used for matching request and response
- [mail # dev]
...Yes the idea of the correlation id is to make it easier for the client tomatch a particular response to the request it answers. Kafka’s protocolallows sending multiple requests without waiti...
, 2017-09-30, 18:43
[KAFKA-1696] Kafka should be able to generate Hadoop delegation tokens
...For access from MapReduce/etc jobs run on behalf of a user....
, 2017-09-23, 04:28
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by