clear query| facets| time Search criteria: .   Results from 1 to 10 from 24184 (0.0s).
Loading phrases to help you
refine your search...
[expand - 9 more] - [VOTE] KIP-527: Add VoidSerde to Serdes - Kafka - [mail # dev]
...Hello.This KIP adopted by commit - https://github.com/apache/kafka/commit/4e094217f7360becd3640a38587e25f9a3bfd4b3Thanks Sophie and Matthias for the review and merge.Thanks Guozhang, Bill, M...
   Author: Nikolay Izhikov , Guozhang Wang , ... , 2019-10-19, 06:38
[expand - 23 more] - Running a stand alone Mirror Maker 2.0 cluster and Issues - Kafka - [mail # user]
...Here is what I see* The max tasks are a a cap  on a Connector across the cluster. If have 8VMs but 8 max tasks my assumption  that there would be 8 * 8 = 72 taskthreads waswring. T...
   Author: Vishal Santoshi , Ryanne Dolan , ... , 2019-10-19, 06:28
[KAFKA-6108] Synchronizing on commits and StandbyTasks can be improved - Kafka - [issue]
...In Kafka Streams, we use an optimization that allows us to reuse a source topic as changelog topic (and thus, avoid unnecessary data duplication) if we read a topic directly as KTable. To gu...
http://issues.apache.org/jira/browse/KAFKA-6108    Author: Matthias J. Sax , 2019-10-19, 05:16
[KAFKA-4996] Fix findbugs multithreaded correctness warnings for streams - Kafka - [issue]
...Fix findbugs multithreaded correctness warnings for streamsMultithreaded correctness Warnings                            ...
http://issues.apache.org/jira/browse/KAFKA-4996    Author: Colin McCabe , 2019-10-19, 05:12
[KAFKA-8769] Consider computing stream time independently per key - Kafka - [issue]
...Currently, Streams uses a concept of "stream time", which is computed as the highest timestamp observed by stateful operators, per partition. This concept of time backs grace period, retenti...
http://issues.apache.org/jira/browse/KAFKA-8769    Author: John Roesler , 2019-10-19, 02:25
[expand - 2 more] - [DISCUSS] KIP-539: Implement mechanism to flush out records in low volume suppression buffers - Kafka - [mail # dev]
...Hi Bill,Thanks for the input!TBH, I am think that suppression buffers are not used *in response *to lowtraffic conditions.Rather, we are trying to fix the situation when low traffic conditio...
   Author: Richard Yu , Bill Bejeck , ... , 2019-10-19, 02:17
[KAFKA-9061] StreamStreamJoinIntegrationTest flaky test failures - Kafka - [issue]
...It looks like one test timed out during cleanup and all other tests failed due to lack of cleanup.See attachment for detailed stack traces....
http://issues.apache.org/jira/browse/KAFKA-9061    Author: Chris Pettitt , 2019-10-19, 00:04
[KAFKA-8455] Add VoidSerde to Serdes - Kafka - [issue]
...Often, when reading an input topic, the key is expected to be null, but there's actually no way to represent this fact in Consumed, leading to confusing type signatures down the topology.For...
http://issues.apache.org/jira/browse/KAFKA-8455    Author: John Roesler , 2019-10-18, 23:54
[KAFKA-9041] Flaky Test LogCleanerIntegrationTest#testIsThreadFailed - Kafka - [issue]
...https://builds.apache.org/job/kafka-pr-jdk11-scala2.13/2622/testReport/junit/kafka.log/LogCleanerIntegrationTest/testIsThreadFailed/java.lang.AssertionError: expected:<1> but was:<0...
http://issues.apache.org/jira/browse/KAFKA-9041    Author: Matthias J. Sax , 2019-10-18, 23:21
[KAFKA-8994] Streams should expose standby replication information & allow stale reads of state store - Kafka - [issue]
...Currently Streams interactive queries (IQ) fail during the time period where there is a rebalance in progress. Consider the following scenario in a three node Streams cluster with node A, no...
http://issues.apache.org/jira/browse/KAFKA-8994    Author: Vinoth Chandar , 2019-10-18, 22:23