| clear query|facets|time |
Search criteria: .
Results from 1 to 10 from
6695 (0.167s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[KAFKA-1901] Move Kafka version to be generated in code by build (instead of in manifest) - Kafka - [issue]
|
|
...With 0.8.2 (rc2), I've started seeing this warning in the logs of apps deployed to our staging (both server and client):2015-01-23 00:55:25,273 WARN [async-message-sender-0] common.App...
|
|
|
|
|
|
|
|
[expand - 2 more]
[collapse]
-
Re: Poor performance running performance test - Kafka - [mail # user]
|
|
...I was running the performance command from a virtual box server, so thatseems like it was part of the problem. I'm getting better results runningthis on a server on aws, but that's kin...
|
|
|
|
|
|
|
|
[expand - 4 more]
[collapse]
-
Re: Can't create a topic; can't delete it either - Kafka - [mail # user]
|
|
...Do you still have the controller and state change logs from the timeyou originally tried to delete the topic?On Tue, Jan 27, 2015 at 03:11:48PM -0800, Sumit Rangwala wrote: ...
|
|
|
|
|
| |
|
|
Re: Can't create a topic; can't delete it either - Kafka - [mail # user]
|
|
...I am using 0.8.2-beta on brokers 0.8.1.1 for client (producer andconsumers). delete.topic.enable=true on all brokers. replication factor is< number of brokers. I see this issue with just ...
|
|
|
Author: Sumit Rangwala,
2015-01-27, 23:12
|
|
|
Re: Can't create a topic; can't delete it either - Kafka - [mail # user]
|
|
...Also, do you have delete.topic.enable=true on all brokers?The automatic topic creation can fail if the default number ofreplicas is greater than number of available brokers. Check thedefault...
|
|
|
Author: Gwen Shapira,
2015-01-27, 17:47
|
|
|
Re: Can't create a topic; can't delete it either - Kafka - [mail # user]
|
|
...Which version of the broker are you using?On Mon, Jan 26, 2015 at 10:27:14PM -0800, Sumit Rangwala wrote: ...
|
|
|
Author: Joel Koshy,
2015-01-27, 08:30
|
|
|
Can't create a topic; can't delete it either - Kafka - [mail # user]
|
|
...While running kafka in production I found an issue where a topic wasn'tgetting created even with auto topic enabled. I then went ahead and createdthe topic manually (from the command line). ...
|
|
|
Author: Sumit Rangwala,
2015-01-27, 06:29
|
|
|
|
|
[expand - 1 more]
[collapse]
-
Re: Ques regarding topic partition offset - Kafka - [mail # user]
|
|
...This can happen as a result of unclean leader elections - there arembeans on the controller that give the unclean leader election rate -or you can check the controller logs to determine if t...
|
|
|
|
|
| |
|
|
Ques regarding topic partition offset - Kafka - [mail # user]
|
|
...Hi ,I have query regarding partition offset .While running kafka cluster for some time ,I noticed that the partitionoffset keeps on increasing and at some point the offset decreased by somen...
|
|
|
Author: Liju John,
2015-01-28, 05:55
|
|
|
|
|
[expand - 2 more]
[collapse]
-
Re: [DISCUSSION] generate explicit error/failing metrics - Kafka - [mail # dev]
|
|
...Joel, thanks for the clarifications.maybe I misunderstand the intent of that metric. Yes, we are looking foralerting if some partitions aren't owned by any consumer from the group(just in ca...
|
|
|
|
|
|
|
|
[expand - 5 more]
[collapse]
-
Re: [DISCUSSION] Boot dependency in the new producer - Kafka - [mail # user]
|
|
...Steven,You are right, I was wrong about the previous email: it will not set theflag, the Sender thread will trigger Client.poll() but with Int.Max selecttime, hence this should not be an iss...
|
|
|
|
|
| |
|
|
Re: [DISCUSSION] Boot dependency in the new producer - Kafka - [mail # user]
|
|
...Jay, I don't think this line will bootstrap full metadata (for all topics).it will just construct the cluster object with bootstrap host. you need todo "metadata.add(topic)" to set int...
|
|
|
Author: Steven Wu,
2015-01-27, 00:43
|
|
|
Re: [DISCUSSION] Boot dependency in the new producer - Kafka - [mail # user]
|
|
...Oh, yes, I guess I thought you meant that construction of the client wouldblock on the metadata request.I don't personally think that is a problem because if it fails it willretry in the bac...
|
|
|
Author: Jay Kreps,
2015-01-26, 22:10
|
|
|
Re: [DISCUSSION] Boot dependency in the new producer - Kafka - [mail # user]
|
|
...It will set the needUpdate flag to true and hence the background Senderwill try to talk to the bootstrap servers.GuozhangOn Mon, Jan 26, 2015 at 1:12 PM, Jay Kreps wrote: ...
|
|
|
Author: Guozhang Wang,
2015-01-26, 21:35
|
|
|
Re: [DISCUSSION] Boot dependency in the new producer - Kafka - [mail # dev]
|
|
...Hey Guozhang,That line shouldn't cause any connections to Kafka to be established, doesit? All that is doing is creating the Cluster pojo using the suppliedaddresses. The use of InetSocketAd...
|
|
|
Author: Jay Kreps,
2015-01-26, 21:14
|
|
|
[DISCUSSION] Boot dependency in the new producer - Kafka - [mail # dev]
|
|
...Hi all,I am not sure if we have discussed about this before, but recently Irealized that we have introduced boot dependency of the kafka-serverspecified by the "bootstrap.servers" config in ...
|
|
|
Author: Guozhang Wang,
2015-01-26, 18:52
|
|
|
|
|
[KAFKA-1235] Enable server to indefinitely retry on controlled shutdown - Kafka - [issue]
|
|
...Today the kafka server can exit silently if it hits an exception that is swallowed during controlled shut down or "controlled.shutdown.max.retries" has been exhausted. It is better to add an...
|
|
|
|
|
|
|
|
[expand - 6 more]
[collapse]
-
Re: SimpleConsumer leaks sockets on an UnresolvedAddressException - Kafka - [mail # user]
|
|
...Ewen, you are right, the patch is committed on Feb.20th last year, I willleave a comment and close that ticket.On Tue, Jan 27, 2015 at 7:24 PM, Ewen Cheslack-Postava wrote: ...
|
|
|
|
|
| |
|
|
Re: SimpleConsumer leaks sockets on an UnresolvedAddressException - Kafka - [mail # user]
|
|
...This was fixed in commit 6ab9b1ecd8 for KAFKA-1235 and it looks like thatwill only be included in 0.8.2.Guozhang, it looks like you wrote the patch, Jun reviewed it, but the bugis still open...
|
|
|
Author: Ewen Cheslack-Postava,
2015-01-28, 03:25
|
|
|
Re: SimpleConsumer leaks sockets on an UnresolvedAddressException - Kafka - [mail # user]
|
|
...Here is the relevant stack trace:java.nio.channels.UnresolvedAddressException: null at sun.nio.ch.Net.checkAddress(Net.java:127) ~[na:1.7.0_55] &n...
|
|
|
Author: Rajiv Kurian,
2015-01-27, 18:23
|
|
|
Re: SimpleConsumer leaks sockets on an UnresolvedAddressException - Kafka - [mail # user]
|
|
...I am using 0.8.1. The source is here:https://github.com/apache/kafka/blob/0.8.1/core/src/main/scala/kafka/consumer/SimpleConsumer.scalaHere is the definition of disconnect():private def disc...
|
|
|
Author: Rajiv Kurian,
2015-01-27, 18:20
|
|
|
Re: SimpleConsumer leaks sockets on an UnresolvedAddressException - Kafka - [mail # user]
|
|
...Rajiv,Which version of Kafka are you using? I just checked SimpleConsumer's code,and in its close() function, disconnect() is called, which will close thesocket.GuozhangOn Mon, Jan 26, 2015 ...
|
|
|
Author: Guozhang Wang,
2015-01-27, 17:04
|
|
|
Re: SimpleConsumer leaks sockets on an UnresolvedAddressException - Kafka - [mail # user]
|
|
...Meant to write a run loop.void run() { while (running) { if (simpleConsumer == null) { simpleConsumer = new SimpleConsumer(host, port,(i...
|
|
|
Author: Rajiv Kurian,
2015-01-26, 22:37
|
|
|
SimpleConsumer leaks sockets on an UnresolvedAddressException - Kafka - [mail # user]
|
|
...Here is my typical flow:void run() { if (simpleConsumer == null) { simpleConsumer = new SimpleConsumer(host, port, (int) kafkaSocketTimeout,kafkaRExeiveBufferSiz...
|
|
|
Author: Rajiv Kurian,
2015-01-26, 22:30
|
|
|
|
|
[KAFKA-1902] fix MetricName so that Yammer reporter can work correctly - Kafka - [issue]
|
|
...Currently, we create MetricName in the following format.group: "kafka.server"type: "BrokerTopicMetrics"name: "BytesInPerSec"scope: nullmBeanName: "kafka.server:type=BrokerTopicMetrics,name=B...
|
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
Re: Registry used for yammer metrics in Kafka - Kafka - [mail # dev]
|
|
...I think having dedicated registries would have been a better choice -it sort of just ended up like this. We made note of this in KAFKA-1567as well if you read through those comments but conc...
|
|
|
|
|
| |
|
|
Registry used for yammer metrics in Kafka - Kafka - [mail # dev]
|
|
...IIUC, Kafka uses the default registry in yammer metrics to create all kafkarelated metrics. We observed a scenario where we found that our defaultregistry was getting populated by the metric...
|
|
|
Author: Sumit Rangwala,
2015-01-27, 23:42
|
|
|
|
|
|
|
|
|
