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: story short: it's a mess to get a KStream<>[] out from KStream<>...    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]    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.
   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...    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...    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", () => s...    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...    Author: Boyang Chen , 2020-05-28, 21:24
[KAFKA-9130] Allow listing consumer groups per state - Kafka - [issue]
...Ticket for KIP-518:    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...    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...    Author: Jason Gustafson , 2020-05-28, 20:26