clear query| facets| time Search criteria: .   Results from 1 to 10 from 140 (0.0s).
Loading phrases to help you
refine your search...
[KAFKA-9713] Remove BufferExhausedException - Kafka - [issue]
...BufferExhaustedException was deprecated in, and the corresponding block.on.buffer.full property has since been removed. The exception should follow.Deprecations in produce...    Author: Brian Byrne , 2020-03-28, 13:38
[KAFKA-3720] Remove BufferExhaustException from doSend() in KafkaProducer - Kafka - [issue]
...KafkaProducer no longer throws BufferExhaustException. We should remove it from the catch clause....    Author: Mayuresh Gharat , 2020-03-28, 13:38
[KAFKA-9782] Kafka Connect InsertField transform - Add the ability to insert event's Key into Value - Kafka - [issue]
...I'm using Debezium to pull change data capture events from a Mongo DB and write them to S3 with the Confluent S3 Sink. The problem is Debezium stores the document's key in each event's key a...    Author: Ryan Tomczik , 2020-03-28, 13:29
[KAFKA-9166] Implement MetadataFetch API - Kafka - [issue]
...Brief description of the ask is mentioned in KIP-500's BrokerMetadataManagementInstead of the controller pushing out updates to the other brokers, those brokers will fetch updates from the a...    Author: Viktor Somogyi-Vass , 2020-03-28, 09:42
[KAFKA-9781] TimestampConverter / Allow to specify a time zone when converting unix epoch to string - Kafka - [issue]
...TimestampConverter can convert a unix epoch value (long; number of milliseconds since Jan 01 1970 00:00 GMT) to string. However, when doing such conversion, the string result depends on the ...    Author: Al , 2020-03-28, 09:41
[expand - 7 more] - [VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
...I agree with Guozhang that the issue only arises for the`read-process-write` pattern and thus we should guard at the read levelalready and thus auto-downgrading the write path commitTx reque...
   Author: Matthias J. Sax , Guozhang Wang , ... , 2020-03-28, 08:32
[KAFKA-4587] Rethink Unification of Caching with Dedupping - Kafka - [issue]
...This is discussed in PR order to support user-customizable state store suppliers in the DSL we did the following:1) Introduce a TupleForwarder to ...    Author: Guozhang Wang , 2020-03-28, 07:56
[KAFKA-6443] KTable involved in multiple joins could result in duplicate results - Kafka - [issue]
...Consider the following multi table-table joins:table1.join(table2).join(table2);    // "join" could be replaced with "leftJoin" and "outerJoin"where table2 is involved multiple tim...    Author: Guozhang Wang , 2020-03-28, 07:51
[KAFKA-7965] Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup - Kafka - [issue]
...To get stable nightly builds for `2.2` release, I create tickets for all observed test failures. Receiv...    Author: Matthias J. Sax , 2020-03-28, 07:41
[KAFKA-9769] ReplicaManager Partition.makeFollower Increases LeaderEpoch when ZooKeeper disconnect occurs - Kafka - [issue]
...The ZooKeeper Session once expired and got disconnected and the broker received the 1st LeaderAndIsr request simultaneously. As the broker was processing the 1st LeaderAndIsr Request, the Zo...    Author: Andrew Choi , 2020-03-28, 04:18