clear query| facets| time Search criteria: .   Results from 1 to 10 from 177 (0.0s).
Loading phrases to help you
refine your search...
Tumbling Time Window - Kafka - [mail # user]
...Hi All,I'm trying to create a tumbling time window of two seconds using PAPI. Ihave a TimestampWindowStore with both retention and window size as 2seconds and retainDuplicates as false.Store...
   Author: Navneeth Krishnan , 2019-10-15, 07:56
[KAFKA-9043] Problem committing offsets when using consumer subscribe and assign method on different topics with same group.id - Kafka - [issue]
...I am using a consumer with group.id "myGroup" on an empty topic "election" with 24 partitions in subscribe mode. The poll loop is a noop and is for rebalancing only. On new assigments (only ...
http://issues.apache.org/jira/browse/KAFKA-9043    Author: Michael Arndt , 2019-10-15, 07:43
[KAFKA-4133] Provide a configuration to control consumer max in-flight fetches - Kafka - [issue]
...With KIP-74, we now have a good way to limit the size of fetch responses, but it may still be difficult for users to control overall memory since the consumer will send fetches in parallel t...
http://issues.apache.org/jira/browse/KAFKA-4133    Author: Jason Gustafson , 2019-10-15, 07:12
[KAFKA-9011] Add KStream#flatTransform and KStream#flatTransformValues to Scala API - Kafka - [issue]
...Part of KIP-313: https://cwiki.apache.org/confluence/display/KAFKA/KIP-313%3A+Add+KStream.flatTransform+and+KStream.flatTransformValues ...
http://issues.apache.org/jira/browse/KAFKA-9011    Author: Alex Kokachev , 2019-10-15, 07:04
[KAFKA-4422] Drop support for Scala 2.10 (KIP-119) - Kafka - [issue]
...Now that Scala 2.12 has been released, we should drop support for Scala 2.10  in the next major Kafka version so that we keep the number of supported versions at 2. Since we have to com...
http://issues.apache.org/jira/browse/KAFKA-4422    Author: Ismael Juma , 2019-10-15, 06:24
[KAFKA-9042] Auto infer external topic partitions in stream reset tool - Kafka - [issue]
...As of today, user has to specify `--input-topic` in the stream reset to be able to reset offset to a specific position. For a stream job with multiple external topics that needs to be purged...
http://issues.apache.org/jira/browse/KAFKA-9042    Author: Boyang Chen , 2019-10-15, 06:12
[KAFKA-8671] NullPointerException occurs if topic associated with GlobalKTable changes - Kafka - [issue]
...The following NullPointerException occurs when the global/.checkpoint file contains a line with a topic previously associated with (but no longer configured for) a GlobalKTable:java.lang.Nul...
http://issues.apache.org/jira/browse/KAFKA-8671    Author: Alex Leung , 2019-10-15, 05:02
[KAFKA-8967] Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig - Kafka - [issue]
...java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.UnknownTopicOrPartitionException: This server does not host this topic-partition. at org.apache.kafka.common.internals...
http://issues.apache.org/jira/browse/KAFKA-8967    Author: Stanislav Kozlovski , 2019-10-15, 04:47
[KAFKA-9022] Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues - Kafka - [issue]
...array lengths differed, expected.length=2 actual.length=1; arrays first differed at element [0]; expected:<KeyValue(3, value1=9.99,value2=90)> but was:<KeyValue(3, value1=1....
http://issues.apache.org/jira/browse/KAFKA-9022    Author: Sophie Blee-Goldman , 2019-10-15, 04:45
[KAFKA-8264] Flaky Test PlaintextConsumerTest#testLowMaxFetchSizeForRequestAndPartition - Kafka - [issue]
...https://builds.apache.org/blue/organizations/jenkins/kafka-2.0-jdk8/detail/kafka-2.0-jdk8/252/testsorg.apache.kafka.common.errors.TopicExistsException: Topic 'topic3' already exists.STDOUT &...
http://issues.apache.org/jira/browse/KAFKA-8264    Author: Matthias J. Sax , 2019-10-15, 04:44