| clear
query|
facets|
time |
Search criteria: .
Results from 1 to 10 from
66904 (0.0s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[KAFKA-6817] UnknownProducerIdException when writing messages with old timestamps -
Kafka - [issue]
|
| ...We are seeing the following exception in our Kafka application: ERROR o.a.k.s.p.internals.StreamTask - task [0_0] Failed to close producer due to the following error: org.apache.kafka.stream... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
Using Kafka as Primary Datastore without compaction -
Kafka - [mail # dev]
|
| ...As per my understanding, you should set the retention period to Long.MAXhours. This will ensure that your messages won't get compacted becauseretention period is huge.Regards,AmanOn Mon, Jun... |
|
|
|
|
| |
|
Using Kafka as Primary Datastore without compaction - Kafka - [mail # dev]
|
| ...Hi There, I am currently reading the Kafka Definitive guide book as we wanted to Architect an application using Kafka as the primary data store. In the Log Compaction section you have mentio... |
|
|
|
|
|
|
|
[expand - 2 more]
[collapse]
-
Retries -
Kafka - [mail # user]
|
| ...The thing about that is, when I try to register the handler, it doesn’t work. It’s easy to register the deserialization handler because there is a static final constant variable I can ... |
|
|
|
|
| |
|
Retries - Kafka - [mail # user]
|
| ...Michael,It depends on the semantics you want to get. About retries in general,as long as a producer retries internally, you would not even notice.Only after retries are exhausted, an excepti... |
|
|
|
|
|
Retries - Kafka - [mail # user]
|
| ...Hi I am trying to understand when to retry sending messages to topics and when to start trying to send to "retry" topics. The scenario is basically1. A KafkaStreams application is cons... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
Process messages from StateStore -
Kafka - [mail # user]
|
| ...Jozsef,Your question is a little unclear to me.> To detect lost messages For what topology?>> KTable inputTable = builder.table("inputTopic",>> Consumed.with(...).filter(...))... |
|
|
|
|
| |
|
Process messages from StateStore - Kafka - [mail # user]
|
| ...Hi!I have an application which uses an input and output topic, and everymessage from the input topic should have a corresponding message (with thesame key) in the output topic.To detect lost... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
Kafka Streams Session store fetch latency very high with caching turned on -
Kafka - [mail # user]
|
| ...Sam,Thanks for your email. This is a very interesting find. I did not doublecheck the code but your reasoning makes sense to me. Note, that cachingwas _not_ introduced to reduce the writes t... |
|
|
|
|
|
|
|
[KAFKA-6964] Add ability to print all internal topic names -
Kafka - [issue]
|
| ...For security access reasons some streams users need to build all internal topics before deploying their streams application. While it's possible to get all internal topic names from the Top... |
|
|
|
|
|
|
|
[KAFKA-5054] ChangeLoggingKeyValueByteStore delete and putIfAbsent should be synchronized -
Kafka - [issue]
|
| ...putIfAbsent and delete should be synchronized as they involve at least 2 operations on the underlying store and may result in inconsistent results if someone were to query via IQ... |
|
|
|
|
|
|
|
[KAFKA-6037] Make Sub-topology Parallelism Tunable -
Kafka - [issue]
|
| ...Today the downstream sub-topology's parallelism (aka the number of tasks) are purely dependent on the upstream sub-topology's parallelism, which ultimately depends on the source topic's num.... |
|
|
|
|
|
|
|
[expand - 26 more]
[collapse]
-
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors -
Kafka - [mail # dev]
|
| ...Sorry to hear! Get well soon!It's not a big deal if the KIP stalls a little bit. Feel free to pick itup again when you find time.>>> Is `StreamThreadNotRunningException` really an r... |
|
|
|
|
| |
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Matthias,Thank you for your assistance.> what is the status of this KIP?Unfortunately, there is no further progress.About seven weeks ago, I was injured in sports. I had a broken wrist on... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Vito,what is the status of this KIP?I just re-read it, and have a couple of follow up comments. Why do wediscuss the internal exceptions you want to add? Also, do we really needthem? Can't w... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Hi, Guozhang,Thanks for the comment!Hi, Bill,I'll try to make some update to make the KIP better.Thanks for the comment!---VitoOn Sat, Apr 21, 2018 at 5:40 AM, Bill Bejeck wrote:> H... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Hi, John,Thanks for the comment!KIP typically discuss the public interfaces, non-user-facing detail is notnecessary.I think your opinion is correct.But in this KIP, when a state store except... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Hi, Matthias,Thanks for the review!I have updated the KIP, please look again.Thanks.---VitoOn Thu, Apr 19, 2018 at 9:58 PM, Matthias J. Sax wrote:> Thanks for clarification! That makes se... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Hi Vito,Thanks for the KIP, overall it's a +1 from me.At this point, the only thing I would change is possibly removing thelisting of all methods called by the user and the listing of all st... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Thanks for the KIP Vito!I made a pass over the wiki and it looks great to me. I'm +1 on the KIP.About the base class InvalidStateStoreException itself, I'd actuallysuggest we do not deprecat... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Hi Vito,Thanks for the KIP!I think it's much nicer to give callers different exceptions to tell themwhether the state store got migrated, whether it's still initializing, orwhether there's s... |
|
|
|
|
|
[DISCUSS]KIP-216: IQ should throw different exceptions for different errors - Kafka - [mail # dev]
|
| ...Thanks for clarification! That makes sense to me.Can you update the KIP to make those suggestions explicit?-MatthiasOn 4/18/18 2:19 PM, vito jeng wrote:> Matthias,> > Thanks for the... |
|
|
|
|
|
|
|
[expand - 3 more]
[collapse]
-
[VOTE] KIP-313: Add KStream.flatTransform and KStream.flatTransformValues -
Kafka - [mail # dev]
|
| ...+1 (binding)-MatthiasOn 6/22/18 10:25 AM, Bill Bejeck wrote:> Thanks for the KIP, +1.> > -Bill> > On Fri, Jun 22, 2018 at 1:08 PM Ted Yu wrote:> >> +1>>&g... |
|
|
|
|
| |
|
[VOTE] KIP-313: Add KStream.flatTransform and KStream.flatTransformValues - Kafka - [mail # dev]
|
| ...Thanks for the KIP, +1.-BillOn Fri, Jun 22, 2018 at 1:08 PM Ted Yu wrote:> +1>> On Fri, Jun 22, 2018 at 2:50 AM, Bruno Cadonna wrote:>> > Hi list,> >> ... |
|
|
|
|
|
[VOTE] KIP-313: Add KStream.flatTransform and KStream.flatTransformValues - Kafka - [mail # dev]
|
| ...+1On Fri, Jun 22, 2018 at 2:50 AM, Bruno Cadonna wrote:> Hi list,>> I would like to voting on this KIP.>> I created a first PR[1] that adds flatTransform. Once I get som... |
|
|
Author: Ted Yu ,
2018-06-22, 17:08
|
|
|
|
[VOTE] KIP-313: Add KStream.flatTransform and KStream.flatTransformValues - Kafka - [mail # dev]
|
| ...Hi list,I would like to voting on this KIP.I created a first PR[1] that adds flatTransform. Once I get somefeedback, I will start work on flatTransformValues.Best regards,Bruno[1] https://gi... |
|
|
|
|
|
|
|
|