| clear
query|
facets|
time |
Search criteria: .
Results from 1 to 10 from
3820 (0.0s).
|
|
|
Loading phrases to help you
refine your search...
|
|
[KAFKA-9713] Remove BufferExhausedException -
Kafka - [issue]
|
| ...BufferExhaustedException was deprecated in 0.9.0.0, and the corresponding block.on.buffer.full property has since been removed. The exception should follow.Deprecations in 0.9.0.0The produce... |
|
|
|
|
|
|
|
[KAFKA-3720] Remove BufferExhaustException from doSend() in KafkaProducer -
Kafka - [issue]
|
| ...KafkaProducer no longer throws BufferExhaustException. We should remove it from the catch clause.... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
[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 ... |
|
|
|
|
|
|
|
[expand - 23 more]
[collapse]
-
[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... |
|
|
|
|
| |
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...Hello Colin, Ismael,Thanks for your feedbacks, they are quite helpful. Just to provide somecontext here about OffsetFetch:1) When building the offset fetch request, we used to auto "downgrad... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...I'm a bit puzzled. We added this feature because we thought it was useful.And now we are saying that you don't know if you can rely on it since thedowngrade happens silently. Can you provide... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...Thanks Colin, I think the point of this change is to make the new clientexperience better while working with old brokers, when the upgrade ishappening on client side only. For Streams, it is... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...On Fri, Mar 27, 2020, at 18:29, Colin McCabe wrote:> On Fri, Mar 27, 2020, at 16:06, Boyang Chen wrote:> > Hey there,> > > > we would like to address an improvement on t... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...On Fri, Mar 27, 2020, at 16:06, Boyang Chen wrote:> Hey there,> > we would like to address an improvement on the> *Producer#sendOffsetsToTransaction(offsets,> groupMetadata) *... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...Hey there,we would like to address an improvement on the*Producer#sendOffsetsToTransaction(offsets,groupMetadata) *API. Previously we assume the calling of this functionwould crash the app i... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...One more change for KIP-447.Currently, Kafka Streams collects task-level metrics called"commit-latency-[max|avg]". However, with KIP-447 tasks don't getcommitted individually any longer, and... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...-----BEGIN PGP SIGNED MESSAGE-----Hash: SHA512There is one more change to this KIP for the upgrade path of KafkaStreams applications:We cannot detect broker versions reliable, and thus, we n... |
|
|
|
|
|
[VOTE] KIP-447: Producer scalability for exactly once semantics - Kafka - [mail # dev]
|
| ...Boyang,Thanks for the update. This change makes sense to me.GuozhangOn Tue, Feb 11, 2020 at 11:37 AM Boyang Chen wrote:> Hey there,>> we are adding a small change to the KIP-447 pub... |
|
|
|
|
|
|
|
[KAFKA-4587] Rethink Unification of Caching with Dedupping -
Kafka - [issue]
|
| ...This is discussed in PR https://github.com/apache/kafka/pull/1588In order to support user-customizable state store suppliers in the DSL we did the following:1) Introduce a TupleForwarder to ... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
[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.https://jenkins.confluent.io/job/apache-kafka-test/job/2.2/21/java.lang.AssertionError: Receiv... |
|
|
|
|
|
|
|
[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... |
|
|
|
|
|
|
|
|