From d5815948505c5bf0f19e1046405fb2277ca2ccac Mon Sep 17 00:00:00 2001 From: Ruben Bartelink Date: Fri, 13 Nov 2020 08:45:48 +0000 Subject: [PATCH] Fix erroneous acks xmldoc --- src/FsKafka/FsKafka.fs | 10 +++------- src/FsKafka0/FsKafka.fs | 10 +++------- 2 files changed, 6 insertions(+), 14 deletions(-) diff --git a/src/FsKafka/FsKafka.fs b/src/FsKafka/FsKafka.fs index eccd91c..010ded1 100644 --- a/src/FsKafka/FsKafka.fs +++ b/src/FsKafka/FsKafka.fs @@ -45,9 +45,7 @@ type KafkaProducerConfig private (inner, bootstrapServers : string) = /// Creates and wraps a Confluent.Kafka ProducerConfig with the specified settings static member Create - ( clientId : string, bootstrapServers : string, - /// Default: All - acks, + ( clientId : string, bootstrapServers : string, acks, /// Defines combination of linger/maxInFlight settings to effect desired batching semantics batching : Batching, /// Message compression. Default: None. @@ -58,7 +56,7 @@ type KafkaProducerConfig private (inner, bootstrapServers : string) = ?retryBackoff, /// Statistics Interval. Default: no stats. ?statisticsInterval, - /// Ack timeout (assuming Acks != Acks.0). Confluent.Kafka default: 5s. + /// Ack timeout (assuming Acks != Acks.Zero). Confluent.Kafka default: 5s. ?requestTimeout, /// Confluent.Kafka default: false. Defaults to true. ?socketKeepAlive, @@ -97,9 +95,7 @@ type KafkaProducerConfig private (inner, bootstrapServers : string) = [] // TODO remove in 2.0.0 static member Create - ( clientId : string, bootstrapServers : string, - /// Default: All - acks, + ( clientId : string, bootstrapServers : string, acks, /// Message compression. Default: None. ?compression, /// Maximum in-flight requests. Default: 1_000_000. diff --git a/src/FsKafka0/FsKafka.fs b/src/FsKafka0/FsKafka.fs index 6e73bd3..ffe920a 100644 --- a/src/FsKafka0/FsKafka.fs +++ b/src/FsKafka0/FsKafka.fs @@ -45,9 +45,7 @@ type KafkaProducerConfig private (inner, bootstrapServers : string) = /// Creates and wraps a Confluent.Kafka ProducerConfig with the specified settings static member Create - ( clientId : string, bootstrapServers : string, - /// Default: All - acks, + ( clientId : string, bootstrapServers : string, acks, /// Defines combination of linger/maxInFlight settings to effect desired batching semantics batching : Batching, /// Message compression. Default: None. @@ -97,9 +95,7 @@ type KafkaProducerConfig private (inner, bootstrapServers : string) = [] // TODO remove in 2.0.0 static member Create - ( clientId : string, bootstrapServers : string, - /// Default: All - acks, + ( clientId : string, bootstrapServers : string, acks, /// Message compression. Default: None. ?compression, /// Maximum in-flight requests. Default: 1_000_000. @@ -114,7 +110,7 @@ type KafkaProducerConfig private (inner, bootstrapServers : string) = ?retryBackoff, /// Statistics Interval. Default: no stats. ?statisticsInterval, - /// Ack timeout (assuming Acks != Acks.0). Confluent.Kafka default: 5s. + /// Ack timeout (assuming Acks != Acks.Zero). Confluent.Kafka default: 5s. ?requestTimeout, /// Confluent.Kafka default: false. Defaults to true. ?socketKeepAlive,