| clear query|facets|time |
Search criteria: .
Results from 1 to 10 from
7570 (8.249s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[KAFKA-266] Kafka web console - Kafka - [issue]
|
|
...This issue is created to track a community-contributed Kafka Web UI.Here is an initial list of goals:- Be able to easily see which brokers are up- Be able to see lists of topics, connected p...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-266
Author: Evan Chan,
2013-05-25, 11:03
|
|
|
[KAFKA-916] Deadlock between fetcher shutdown and handling partitions with error - Kafka - [issue]
|
|
...Here is another consumer deadlock that we encountered. All consumers arevulnerable to this during a rebalance if there happen to be partitions inerror.On a rebalance, the fetcher manager clo...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-916
Author: Joel Koshy,
2013-05-25, 06:13
|
|
|
[KAFKA-919] Disabling of auto commit is ignored during consumer group rebalancing - Kafka - [issue]
|
|
...From the mailing list:In one of our applications using Kafka, we are using the high-level consumer to pull messages from our topic.Because we pull messages from topics in discrete units (e.g...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-919
Author: Phil Hargett,
2013-05-25, 06:02
|
|
|
[jira] [Commented] (KAFKA-916) Deadlock between fetcher shutdown and handling partitions with error - Kafka - [mail # dev]
|
|
... [ https://issues.apache.org/jira/browse/KAFKA-916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13666973#comment-13666973 ] Jun Ra...
|
|
|
Author: "Jun Rao,
2013-05-25, 05:14
|
|
|
Re: OffsetOutOfRangeException and getOffsetsBefore - Kafka - [mail # user]
|
|
...This gives you back two valid offsets, not a range.Thanks,JunOn Fri, May 24, 2013 at 11:29 AM, Sining Ma wrote:> Hi,> We are currently using kafka-0.7.1 right now.> I have two...
|
|
|
Author: Jun Rao,
2013-05-25, 05:09
|
|
|
[jira] [Resolved] (KAFKA-919) Disabling of auto commit is ignored during consumer group rebalancing - Kafka - [mail # dev]
|
|
... [ https://issues.apache.org/jira/browse/KAFKA-919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]Jun Rao resolved KAFKA-919.--------------------------...
|
|
|
Author: "Jun Rao,
2013-05-25, 05:04
|
|
|
[KAFKA-920] zkclient jar 0.2.0 is not compatible with 0.1.0 - Kafka - [issue]
|
|
...Just realized that zkclient 0.2.0 introduced a non-backward compatible api. In 0.1.0, it has public void writeData(java.lang.String path, java.lang.Object datat) ...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-920
Author: Jun Rao,
2013-05-24, 22:48
|
|
|
[jira] [Updated] (KAFKA-920) zkclient jar 0.2.0 is not compatible with 0.1.0 - Kafka - [mail # dev]
|
|
... [ https://issues.apache.org/jira/browse/KAFKA-920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]Jun Rao updated KAFKA-920:--------------------------&...
|
|
|
Author: "Jun Rao,
2013-05-24, 21:49
|
|
|
Re: OffsetOutOfRangeException and getOffsetsBefore - Kafka - [mail # user]
|
|
...If you use the Java API you can do SimpleConsumer.getOffsetsBefore(topic, partition, time, 1) which will return a long offset valueThe time parameter can be kafka.api.OffsetRequest.EarliestT...
|
|
|
Author: Suyog Rao,
2013-05-24, 21:40
|
|
|
Re: OffsetOutOfRangeException and getOffsetsBefore - Kafka - [mail # user]
|
|
...Thanks SuyogCould you explain more about OffsetRequest?I find newOffsetRequest(topic: String, partition: Int, time: Long, maxNumOffsets: Int)in Kafka api.How can I send this request? And whe...
|
|
|
Author: Sining Ma,
2013-05-24, 21:04
|
|
|
|
