clear query| facets| time Search criteria: .   Results from 31 to 40 from 24137 (0.0s).
Loading phrases to help you
refine your search...
[expand - 3 more] - Long delay between incoming and outgoing messages using kafka streams - Kafka - [mail # user]
...Honestly I can't say whether 256 partitions is enough to trigger theperformance issuesin 2.3.0 but I'd definitely recommend upgrading as soon as you can, just incase. On arelated note, how m...
   Author: Sophie Blee-Goldman , Petter Arvidsson , ... , 2019-10-14, 20:13
[KAFKA-6144] Allow state stores to serve stale reads during rebalance - Kafka - [issue]
...Currently when expanding the KS cluster, the new node's partitions will be unavailable during the rebalance, which for large states can take a very long time, or for small state stores even ...
http://issues.apache.org/jira/browse/KAFKA-6144    Author: Antony Stubbs , 2019-10-14, 20:06
[expand - 7 more] - Running a stand alone Mirror Maker 2.0 cluster and Issues - Kafka - [mail # user]
...>  timed outwhile waiting for producer to flush outstandingYeah, that's what I'd expect to see if Connect was unable to send recordsto the downstream remote topics, e.g. if min.in-sy...
   Author: Ryanne Dolan , Vishal Santoshi , ... , 2019-10-14, 19:42
[expand - 5 more] - Stale data in KStream->KTable join - Kafka - [mail # user]
...I'm not sure you really need to/ should be sending data back to the tablewith .to(table) -- that was kind of the original issue, since it introducesa cycle*into your topology (which should b...
   Author: Sophie Blee-Goldman , Trey Hutcheson , ... , 2019-10-14, 19:29
[expand - 17 more] - [DISCUSS] KIP-448: Add State Stores Unit Test Support to Kafka Streams Test Utils - Kafka - [mail # dev]
...Hi,After some investigations, I updated the KIP and the sample MR again:1. Move the Mocks under test-utils/state2. extends a WrappedStateStore.The reason is that since we decided to provide ...
   Author: Yishun Guan , Matthias J. Sax , ... , 2019-10-14, 18:26
[expand - 3 more] - [VOTE] 2.3.1 RC1 - Kafka - [mail # user]
...Hi David,Probably not a blocker, but I noticed the authorization section in thesecurity docs was not updated in 2.3.0 to include authorizationdetails for ElectPreferredLeaders and Incrementa...
   Author: Mickael Maison , Gwen Shapira , ... , 2019-10-14, 18:11
[KAFKA-9024] org.apache.kafka.connect.transforms.ValueToKey throws NPE - Kafka - [issue]
...If a field named in the SMT does not exist a NPE is thrown. This is not helpful to users and should be caught correctly and reported back in a more friendly way.For example, importing data f...
http://issues.apache.org/jira/browse/KAFKA-9024    Author: Robin Moffatt , 2019-10-14, 17:43
[KAFKA-9039] Optimize replica fetching CPU utilization with large number of partitions - Kafka - [issue]
...Our current follower replica fetching logic has huge CPU cost with num.partitions to fetch from, and it scales non-linearly as well. There are a bunch of optimizations we can consider to try...
http://issues.apache.org/jira/browse/KAFKA-9039    Author: Guozhang Wang , 2019-10-14, 17:37
[expand - 1 more] - [DISCUSS] KIP-535: Allow state stores to serve stale reads during rebalance - Kafka - [mail # dev]
...Hi Navinder,Thanks for sharing the KIP! Few thoughts- Can we link the JIRA, discussion thread also to the KIP- Based on the discussion on KAFKA-6144, I was under the impression thatthis KIP ...
   Author: Vinoth Chandar , Navinder Brar , ... , 2019-10-14, 17:06
[expand - 10 more] - [Newbie][IntelliJ Setup] How to run Kafka in IntelliJ - Kafka - [mail # dev]
...Thanks Tao Xiao, It worked.On Mon, Oct 14, 2019 at 9:55 PM tao xiao  wrote:> one more thing you need to do is to include slf4j-log4j in build.gradle as> it is not included as comp...
   Author: chandresh pancholi , tao xiao , ... , 2019-10-14, 16:46