clear query| facets| time Search criteria: .   Results from 21 to 30 from 74739 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-5682] Consumer should include partition in exceptions raised during record parsing/validation - Kafka - [issue]
...When we encounter an exception when validating a fetched record or when deserializing it, we raise it to the user and keep the consumer's current position at the offset of the failed record....    Author: Jason Gustafson , 2018-10-19, 17:41
[KAFKA-7405] Support for graceful handling of corrupted records in Kafka consumer - Kafka - [issue]
...We have run into issues several times where corrupted records cause the Kafka consumer to throw an error code 2 exception (CRC checksum failure) in the fetch layer. Specifically, when using ...    Author: Eugen Feller , 2018-10-19, 17:41
[KAFKA-7299] batch LeaderAndIsr requests during auto preferred leader election - Kafka - [issue]
...Currently, in KafkaController.checkAndTriggerAutoLeaderRebalance(), we call onPreferredReplicaElection() one partition at a time. This means that the controller will be sending LeaderAndIsrR...    Author: Jun Rao , 2018-10-19, 17:24
[KAFKA-7522] As a client of kafka-streams library I want to provide custom error handlers programmatically - Kafka - [issue]
...According to KIP-210 and KIP-161, I can define custom error handlers via properties:default.deserialization.exception.handler=org.apache.kafka.streams.errors.LogAndContinueExceptionHandlerde...    Author: Yevhen Tsyba , 2018-10-19, 16:49
[KAFKA-7508] Kafka broker anonymous disconnected from Zookeeper - Kafka - [issue]
...Hello Team, We are facing below Error , Kafka broker unable to connect Zookeeper , Please check and suggest is there any configuration changes required on Kafka Broker.  ERROR:2018-10-15 12:...    Author: Sathish Yanamala , 2018-10-19, 15:15
[KAFKA-2350] Add KafkaConsumer pause capability - Kafka - [issue]
...There are some use cases in stream processing where it is helpful to be able to pause consumption of a topic. For example, when joining two topics, you may need to delay processing of one to...    Author: Jason Gustafson , 2018-10-19, 13:32
[KAFKA-7520] Adding possibility to configure versions in Mirror Maker ducktape test - Kafka - [issue]
...Currently it is testing the current (dev) version only. It would be nice to test mirror maker between different type of brokers for example.Test: tests/kafkatest/tests/core/mirror_maker_test...    Author: Andras Katona , 2018-10-19, 09:58
[expand - 1 more] - Strange log delete behavior after segment rollover - Kafka - [mail # user]
...Sorry, Please ignore the question of deleting older segments again. Thosewere for other partitions.The only question is about the delay.Thanks,VishnuOn Thu, Oct 18, 2018 at 1:26 PM Vishnu Vi...
   Author: Vishnu Viswanath , 2018-10-18, 20:38
[expand - 7 more] - [VOTE] KIP-376: Implement AutoClosable on appropriate classes that want to be used in a try-with-resource statement - Kafka - [mail # dev]
...Bumping this thread up again, thanks!On Tue, Oct 16, 2018 at 11:24 AM Yishun Guan  wrote:>> Bumping this thread up again, thanks!>> On Fri, Oct 12, 2018, 4:53 PM Colin McCab...
   Author: Yishun Guan , Colin McCabe , ... , 2018-10-18, 18:48
[expand - 11 more] - Throwing away prefetched records optimisation. - Kafka - [mail # dev]
...The idea for you would be that Messagechooser could hang on to the prefetched messages.ccing [EMAIL PROTECTED]@Collinjust for you to see that MessageChooser is a powerfull abstraction.:)Best...
   Author: Jan Filipiak , Zahari Dichev , ... , 2018-10-18, 16:27