| clear
query|
facets|
time |
Search criteria: .
Results from 1 to 10 from
60753 (0.0s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[KAFKA-5539] Kafka Connect plugin.path is not used -
Kafka - [issue]
|
| ...I am trying to set up the plugin.path connect property, but Kafka ignores it.I have used the sample property file in GitHub, but I can not make it work. Also, I tried with both modes: standa... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
Requires suggestions for Producer request throttling -
Kafka - [mail # user]
|
| ...Request quotas was just added to 0.11. Does that help in your use case?https://cwiki.apache.org/confluence/display/KAFKA/KIP-124+-+Request+rate+quotas-hans> On Jun 29, 2017, at 12:55 AM, ... |
|
|
|
|
| |
|
Requires suggestions for Producer request throttling - Kafka - [mail # user]
|
| ...Hi Team,We are having a Kafka cluster with multiple Topics in it and shared with multiple services(clients). Each service will have multiple events source from where they will be pushing mes... |
|
|
|
|
|
|
|
[expand - 21 more]
[collapse]
-
[DISCUSS] Streams DSL/StateStore Refactoring -
Kafka - [mail # dev]
|
| ...Thanks Kyle.On Thu, 29 Jun 2017 at 15:11 Kyle Winkelman wrote:> Hi Damian,>> >>>> When trying to program in the fluent API that has been discussed most> it> >&g... |
|
|
|
|
| |
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...Hi Damian,>>>> When trying to program in the fluent API that has been discussed most it>>>> feels difficult to know when you will actually get an object you can reuse... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # user]
|
| ...I've updated the experimental code with a couple of ways of doing joins.One following the fluent approach and one following the builder approach.The 2 examples can be found here:https://gith... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...> However, I don't understand your argument about putting aggregate()> after the withXX() -- all the calls to withXX() set optional parameters> for aggregate() and not for groupBy()... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...Hi Kyle,Thanks for your input. Really appreciated.On Thu, 29 Jun 2017 at 06:09 Kyle Winkelman wrote:> I like more of a builder pattern even though others have voiced against> it. The r... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...Hi Guozhang,Thanks for the feedbackOn Thu, 29 Jun 2017 at 01:45 Guozhang Wang wrote:> I played the current proposal a bit with https://github.com/dguy/kafka/> tree/dsl-experiment... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...I like more of a builder pattern even though others have voiced against it. The reason I like it is because it makes it clear to the user that a call to KGroupedStream#count will return a KT... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...I played the current proposal a bit with https://github.com/dguy/kafka/tree/dsl-experiment, and here are my observations:1. Personally I prefer "stream.group(mapper) / stream.gr... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...I see your point about "when to add the processor to the topology". Thatis indeed an issue. Not sure it we could allow "updates" to the topology...I don't see any problem with having all the... |
|
|
|
|
|
[DISCUSS] Streams DSL/StateStore Refactoring - Kafka - [mail # dev]
|
| ...> I also think that mixing optional parameters with configs is a bad idea.> Have not proposal for this atm but just wanted to mention it. Hope to> find some time to come up with som... |
|
|
|
|
|
|
|
metric.reporters not working -
Kafka - [mail # user]
|
| ...Hi,I'm trying to use metrics.reporters https://pastebin.com/185HAjq5 butcouldn't get any useful values. All I get is 0.0 or -infinity. What iswrong? I'm referencing it like in this libraryht... |
|
|
|
|
|
|
|
[expand - 4 more]
[collapse]
-
[DISCUSS] KIP-171: Extend Consumer Group Reset Offset for Stream Application -
Kafka - [mail # dev]
|
| ...You're right, I was not considering Zookeeper dependency.I'm starting to like the idea to wrap `reset-offset` from`streams-application-reset`.I will wait a bit for more feedback and work on ... |
|
|
|
|
|
|
|
[expand - 8 more]
[collapse]
-
Weird broker lock-up causing an almost global downtime -
Kafka - [mail # user]
|
| ...Hi Vincent,What version of Kafka/Kafka Streams are you running, more specifically whenthis error occurred?Thanks,BillOn Wed, Jun 28, 2017 at 12:24 PM, Bill Bejeck wrote:> Thanks for... |
|
|
|
|
| |
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...Thanks for the info Vincent.-BillOn Wed, Jun 28, 2017 at 12:19 PM, Vincent Rischmann wrote:> I'm not sure what exactly to search for, but here are a couple of> things.>> First, l... |
|
|
|
|
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...I'm not sure what exactly to search for, but here are a couple ofthings.First, looking at the broker 1, there's this:https://pastebin.com/raw/XMLpjj7J which I find weird, because I'm sure Id... |
|
|
|
|
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...Thanks Vincent.That's a good start for now.If you get a chance to forward some logs that would be great.-BillOn Tue, Jun 27, 2017 at 6:10 PM, Vincent Rischmann wrote:> Sure.>>... |
|
|
|
|
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...Sure.The application reads a topic of keyless events and based on somecriteria of the event, it creates a new key and uses that for`selectKey`.Then I groupByKey and count with 3 differents w... |
|
|
|
|
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...Hi Vincent,Thanks for reporting this. Could you give some details on your setup (topics, partitions and the structure of your streams application) so I can attempt to reproduce the issue?Tha... |
|
|
|
|
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...Hi Vincent,Thanks for reporting this issue. Could you give us some more details (number topics, partitions per topic and the structure of your Kafka Streams application) so we attempt ... |
|
|
|
|
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...On 2017-06-27 14:46 (-0400), Vincent Rischmann wrote: > Hello. so I had a weird problem this afternoon. I was deploying a> streams application and wanted to delete already existi... |
|
|
|
|
|
Weird broker lock-up causing an almost global downtime - Kafka - [mail # user]
|
| ...Hello. so I had a weird problem this afternoon. I was deploying astreams application and wanted to delete already existing internalstates data so I ran kafka-streams-application-reset.sh to ... |
|
|
|
|
|
|
|
[expand - 3 more]
[collapse]
-
don't read message in consumer -
Kafka - [mail # user]
|
| ...Uncomment the line#advertised.listeners with your address & portCreate a fresh topic and retry your test. Let us know what happens.KR,On 29 Jun 2017 2:06 pm, "Anton Mushin" wrote:> ... |
|
|
|
|
| |
|
don't read message in consumer - Kafka - [mail # user]
|
| ...Thanks for your reply. My server.properties:broker.id=0#delete.topic.enable=true#advertised.listeners=PLAINTEXT://your.host.name:9092num.network.threads=3num.io.threads=8socket.send.buffer.b... |
|
|
|
|
|
don't read message in consumer - Kafka - [mail # user]
|
| ...Please share your server configuration. How are you advertising thelisteners?On 29 Jun 2017 13:44, "Anton Mushin" wrote:> Hi everyone,> I use on kafka_2.11-0.10.1.1, and I'm tryi... |
|
|
|
|
|
don't read message in consumer - Kafka - [mail # user]
|
| ...Hi everyone,I use on kafka_2.11-0.10.1.1, and I'm trying check it work. I have Zookeeper and Kafka on one host.I'm calling console producer: "kafka-console-producer.sh --broker-list 10... |
|
|
|
|
|
|
|
[expand - 9 more]
[collapse]
-
Kafka Sometimes Fails to Start on Boot -
Kafka - [mail # user]
|
| ...I have tried changing the port to no avail. You can also see in the firstemail running a: `netstat -tulpn` produces output saying that nothing isusing port 9999. Also seeing as how 90% of th... |
|
|
|
|
| |
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Have you tried changing the configured JMX port? After all, it's possiblethe conflict is between kafka and some other software running on the sameserver.On 28 June 2017 at 21:06, Eric Coan &... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Hello,Unfortunately Kafka does indeed startup and run for a little bit beforecrashing with the above exception, so doing one simple check wouldn't work.I could theoretically keep this script... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Can you not put a service wrapper for startup? It will attempt a restart ifthe executable isn't up and running successfully.I am not familiar with Unix side, but in Windows you can use a pow... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...I am using the same configuration for all brokers. However, each broker isrunning on a completely separate host (I'm not running all three brokers onthe same host). I can get all three runni... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Aren't u using the same JMX port 9999 for all brokers? I dont think it willwork for more than 1 broker.On 28 Jun 2017 8:22 pm, "Eric Coan" wrote:> Hey,>> No worries. I'm start... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Hey,No worries. I'm starting the brokers with a script yes (that ends upgenerating the command I pasted:```KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote=true-Dcom.sun.management.jmxremote.a... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Please forgive my autocorrect options :(On 28 Jun 2017 8:06 pm, "M. Manna" wrote:Hi,OS is not an issue, I have a 3 broker setup and I have experienced this too.How are toy atarting the... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Hi,OS is not an issue, I have a 3 broker setup and I have experienced this too.How are toy atarting the brokers? Is this a concurrent start or have yougot some startup scriptto bring up all ... |
|
|
|
|
|
Kafka Sometimes Fails to Start on Boot - Kafka - [mail # user]
|
| ...Hello,I've recently been doing research into getting our Kafka cluster runningoutside of Mesos (for a couple of reasons). However I'm noticing about 10%of the time Kafka fails to start on bo... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
Kafka logs - server.log & controller.log -
Kafka - [mail # user]
|
| ...All the brokers write to server.log. The broker that happens to be the controller will also write to the controller.log file.-Dave-----Original Message-----From: karan alang [mailto:[... |
|
|
|
|
| |
|
Kafka logs - server.log & controller.log - Kafka - [mail # user]
|
| ...Hi All -in Kafka, i see two different log files - server.log & controller.log files.What specifically gets logged in these log files ?i.e. what are these 2 files meant to log ?... |
|
|
|
|
|
|
|
[KAFKA-5537] Subscribe Earliest is not working as in 0.10.2.1 -
Kafka - [issue]
|
| ...We have seen issue with subscription where auto offset when set to earliest does not behave the same as in 0.10.2.1 release.We have managed to create a repeatable test for this, which passes... |
|
|
|
|
|
|
|
|