clear query| facets| time Search criteria: .   Results from 11 to 20 from 26154 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-10071] TopicCommand tool should make more efficient metadata calls to Kafka Servers - Kafka - [issue]
...This is a follow up from discussion of. KAFKA-9945 https://github.com/apache/kafka/pull/8737 alter, describe, delete all pull down the entire topic list today, in order to support regex matc...
http://issues.apache.org/jira/browse/KAFKA-10071    Author: Vinoth Chandar , 2020-05-30, 02:08
[KAFKA-10055] Add shared internal utility class for Streams module - Kafka - [issue]
...Throughout the code base we added small helper methods (usually static) when needed. Those helpers are often added to classes they don't really belong to (out of convenience) and may lead to...
http://issues.apache.org/jira/browse/KAFKA-10055    Author: Matthias J. Sax , 2020-05-30, 00:46
[KAFKA-10068] Verify HighAvailabilityTaskAssignor performance with large clusters and topologies - Kafka - [issue]
...While reviewing https://github.com/apache/kafka/pull/8668/files, I realized that we should have a similar test to make sure that the new task assignor completes well within the default assig...
http://issues.apache.org/jira/browse/KAFKA-10068    Author: John Roesler , 2020-05-30, 00:33
[KAFKA-9313] Set default for client.dns.lookup to use_all_dns_ips - Kafka - [issue]
...The default setting of the configuration parameter client.dns.lookup is not use_all_dns_ips .  Consequently, by default, if there are multiple IP addresses and the first one fails, the conne...
http://issues.apache.org/jira/browse/KAFKA-9313    Author: Yeva Byzek , 2020-05-30, 00:31
[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-29, 23:41
[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-29, 23:40
[KAFKA-10066] TopologyTestDriver isn't taking record headers into account during de/serialization - Kafka - [issue]
...When testing a Kafka stream we need the TopologyTestDriver.createOutputTopic to take record headers into account.Is it possible to use the record headers when deserialising when using the To...
http://issues.apache.org/jira/browse/KAFKA-10066    Author: Stefaan Dutry , 2020-05-29, 23:35
[KAFKA-9494] Include data type of the config in ConfigEntry - Kafka - [issue]
...Why this request?To provide better validation. Including the data type can significantly improve the validation on client side (be it web or cli or any other client). In the absence of `type...
http://issues.apache.org/jira/browse/KAFKA-9494    Author: Shailesh Panwar , 2020-05-29, 22:30
[KAFKA-8104] Consumer cannot rejoin to the group after rebalancing - Kafka - [issue]
...TL;DR; KafkaConsumer cannot rejoin to the group due to inconsistent AbstractCoordinator.generation (which is NO_GENERATION and AbstractCoordinator.joinFuture (which is succeeded RequestFutur...
http://issues.apache.org/jira/browse/KAFKA-8104    Author: Gregory Koshelev , 2020-05-29, 22:21
[KAFKA-9841] Connector and Task duplicated when a worker join with old generation assignment - Kafka - [issue]
...When using IncrementalCooperativeAssignor.class to assign connectors and tasks.Suppose there is a worker 'W' got some connection issue with the coordinator.During the connection issue, the c...
http://issues.apache.org/jira/browse/KAFKA-9841    Author: Yu Wang , 2020-05-29, 21:59