Matthias J. Sax
Vahid S Hashemian
Ashish K Singh
mail # user
mail # dev
last 7 days (4)
last 30 days (7)
last 90 days (28)
last 6 months (71)
last 9 months (546)
newest on top
oldest on top
. Results from
Loading phrases to help you
refine your search...
[KAFKA-2230] Add a wakeup() call to the new consumer
...The consumer is meant to be used in an event loop where you poll with some timeout. There are sometime instances where you want the consumer to stop waiting on I/O and wake up and do somethi...
, 2015-10-22, 00:21
[KAFKA-658] Implement "Exact Mirroring" functionality in mirror maker
...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...
, 2015-10-13, 21:09
[KAFKA-1682] Security for Kafka
...Parent ticket for security. Wiki and discussion is here:https://cwiki.apache.org/confluence/display/KAFKA/Security...
, 2015-10-12, 05:13
[KAFKA-1955] Explore disk-based buffering in new Kafka Producer
...There are two approaches to using Kafka for capturing event data that has no other "source of truth store":1. Just write to Kafka and try hard to keep the Kafka cluster up as you would a dat...
, 2015-09-21, 11:29
[KAFKA-1893] Allow regex subscriptions in the new consumer
...The consumer needs to handle subscribing to regular expressions. Presumably this would be done as a new api, void subscribe(java.util.regex.Pattern pattern);Some questions/thoughts to ...
, 2015-09-10, 21:11
[KAFKA-2523] New consumer doesn't check magic version
...The new consumer should be checking that messages it reads are in the format it expects (and give a sane error message otherwise) rather than just randomly reading other formats and running ...
, 2015-09-09, 20:13
[KAFKA-1684] Implement TLS/SSL authentication
...Add an SSL port to the configuration and advertise this as part of the metadata request.If the SSL port is configured the socket server will need to add a second Acceptor thread to listen on...
, 2015-08-05, 15:03
[KAFKA-188] Support multiple data directories
...Currently we allow only a single data directory. This means that a multi-disk configuration needs to be a RAID array or LVM volume or something like that to be mounted as a single directory....
, 2015-05-30, 01:45
[KAFKA-1346] Revisit sample start date in metrics under when there is no activity
...The current logic rolls over a new sample when the current window expires and either an event occurs or a read occurs. In either of these the starting time stamp of the new event window is s...
, 2015-05-20, 19:08
[KAFKA-1347] Create a system test for network partitions
...We got some free and rather public QA here:http://aphyr.com/posts/293-call-me-maybe-kafkaWe have since added a configuration to disable unclean leader election which allows you to prefer con...
, 2015-05-13, 01:48
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