Skip to content

Commit 208949f

Browse files
author
Matt Howlett
committed
optional config values for sr and avro
1 parent 631bcd0 commit 208949f

File tree

3 files changed

+404
-336
lines changed

3 files changed

+404
-336
lines changed

src/Confluent.Kafka.Avro/AvroSerdeProviderConfig.cs

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -59,14 +59,22 @@ public class AvroSerdeProviderConfig : SchemaRegistryConfig
5959
///
6060
/// default: 1024
6161
/// </summary>
62-
public int AvroSerializerBufferBytes { set { this.properties[PropertyNames.AvroSerializerBufferBytes] = value.ToString(); } }
62+
public int? AvroSerializerBufferBytes
63+
{
64+
get { return GetInt(PropertyNames.AvroSerializerBufferBytes); }
65+
set { SetObject(PropertyNames.AvroSerializerBufferBytes, value); }
66+
}
6367

6468
/// <summary>
6569
/// Specifies whether or not the Avro serializer should attempt to auto-register
6670
/// unrecognized schemas with Confluent Schema Registry.
6771
///
6872
/// default: true
6973
/// </summary>
70-
public bool AvroSerializerAutoRegisterSchemas { set { this.properties[PropertyNames.AvroSerializerAutoRegisterSchemas] = value.ToString(); } }
74+
public bool? AvroSerializerAutoRegisterSchemas
75+
{
76+
get { return GetBool(PropertyNames.AvroSerializerAutoRegisterSchemas); }
77+
set { SetObject(PropertyNames.AvroSerializerAutoRegisterSchemas, value); }
78+
}
7179
}
7280
}

0 commit comments

Comments
 (0)