clear query| facets| time Search criteria: .   Results from 1 to 10 from 26138 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-5488] KStream.branch should not return a Array of streams we have to access by known index - Kafka - [issue]
...KIP-418: https://cwiki.apache.org/confluence/display/KAFKA/KIP-418%3A+A+method-chaining+way+to+branch+KStreamlong story short: it's a mess to get a KStream<>[] out from KStream<>...
http://issues.apache.org/jira/browse/KAFKA-5488    Author: Marcel childNo͡.de Trautw... , 2020-05-28, 22:46
[KAFKA-9945] TopicCommand should support --if-exists and --if-not-exists when --bootstrap-server is used - Kafka - [issue]
http://issues.apache.org/jira/browse/KAFKA-9945    Author: Colin McCabe , 2020-05-28, 22:45
[VOTE] KIP-418: A method-chaining way to branch KStream - Kafka - [mail # dev]
...Hello all!I'd like to start the vote for KIP-418 which proposes deprecation of current `branch` method and provides a method-chaining based API for branching.https://cwiki.apache.org/conflue...
   Author: Ivan Ponomarev , 2020-05-28, 22:25
[KAFKA-9501] Promote Standby tasks to active tasks without closing them - Kafka - [issue]
...The purpose of StandbyTasks in Kafka Streams is fast failover. However, atm we close StandbyTasks (and create a new active task) if they are promoted to active.While this works ok for persis...
http://issues.apache.org/jira/browse/KAFKA-9501    Author: Matthias J. Sax , 2020-05-28, 22:18
[KAFKA-10030] Throw exception while fetching a key from a single partition - Kafka - [issue]
...StreamThreadStateStoreProvider#stores throws exception whenever taskId is not found, which is not correct behaviour in multi-threaded env where state store partitions are distributed among s...
http://issues.apache.org/jira/browse/KAFKA-10030    Author: Dima R , 2020-05-28, 22:07
[KAFKA-10063] UnsupportedOperation when querying cleaner metrics after shutdown - Kafka - [issue]
...We have a few log cleaner metrics which iterate the set of cleaners. For example:  newGauge("max-clean-time-secs", () => cleaners.iterator.map(_.lastStats.elapsedSecs).max.toInt)It s...
http://issues.apache.org/jira/browse/KAFKA-10063    Author: Jason Gustafson , 2020-05-28, 21:27
[KAFKA-9146] Add option to force delete members in stream reset tool - Kafka - [issue]
...Sometimes people want to reset the stream application sooner, but blocked by the left-over members inside group coordinator, which only expire after session timeout. When user configures a r...
http://issues.apache.org/jira/browse/KAFKA-9146    Author: Boyang Chen , 2020-05-28, 21:24
[KAFKA-9130] Allow listing consumer groups per state - Kafka - [issue]
...Ticket for KIP-518: https://cwiki.apache.org/confluence/display/KAFKA/KIP-518%3A+Allow+listing+consumer+groups+per+state...
http://issues.apache.org/jira/browse/KAFKA-9130    Author: Mickael Maison , 2020-05-28, 20:58
[KAFKA-10062] Add a method to retrieve the current timestamp as known by the Streams app - Kafka - [issue]
...Please add to the ProcessorContext a method to retrieve current timestamp compatible with Punctuator#punctate(long) method.Proposal in ProcessorContext:long getTimestamp(PunctuationType type...
http://issues.apache.org/jira/browse/KAFKA-10062    Author: Piotr Smolinski , 2020-05-28, 20:54
[KAFKA-10061] Flaky Test `ReassignPartitionsIntegrationTest .testCancellation` - Kafka - [issue]
...We have seen this a few times:org.scalatest.exceptions.TestFailedException: Timed out waiting for verifyAssignment result VerifyAssignmentResult(Map(foo-0 -> PartitionReassignmentState(Li...
http://issues.apache.org/jira/browse/KAFKA-10061    Author: Jason Gustafson , 2020-05-28, 20:26