Skip to content

Commit a139311

Browse files
emaalberoemaalbero
committed
removed producer dispose
1 parent 28e046e commit a139311

File tree

11 files changed

+37
-38
lines changed

11 files changed

+37
-38
lines changed

‎core/Kafka/Internal/RecordCollector.cs

+1-1
Original file line numberDiff line numberDiff line change
@@ -135,7 +135,7 @@ public void Close()
135135
"There are messages still pending to retry in the backpressure queue. These messages won't longer flush into the corresponding topic !");
136136

137137
retryRecordContext.Clear();
138-
producer.Dispose();
138+
//producer.Dispose();
139139
producer = null;
140140
CheckForException();
141141
}

‎core/Processors/Internal/TaskManager.cs

-1
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,6 @@ internal TaskManager(InternalTopologyBuilder builder, TaskCreator taskCreator, I
6161
Consumer = consumer;
6262
}
6363

64-
6564
public void CreateTasks(ICollection<TopicPartition> assignment)
6665
{
6766
CurrentTask = null;

‎core/Streamiz.Kafka.Net.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,11 @@
1919
<PackageIconUrl>https://raw.githubusercontent.com/LGouellec/kafka-streams-dotnet/master/resources/logo-kafka-stream-net.png</PackageIconUrl>
2020
<SignAssembly>true</SignAssembly>
2121
<AssemblyOriginatorKeyFile>..\key.snk</AssemblyOriginatorKeyFile>
22-
<VersionPrefix>1.6.1.109</VersionPrefix>
22+
<VersionPrefix>1.6.1.110</VersionPrefix>
2323
<VersionSuffix>custom</VersionSuffix>
24-
<PackageVersion>1.6.1.109-custom</PackageVersion>
25-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
26-
<FileVersion>1.6.1.109</FileVersion>
24+
<PackageVersion>1.6.1.110-custom</PackageVersion>
25+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
26+
<FileVersion>1.6.1.110</FileVersion>
2727
</PropertyGroup>
2828

2929
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

‎metrics/Streamiz.Kafka.Net.Metrics.OpenTelemetry/Streamiz.Kafka.Net.Metrics.OpenTelemetry.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,11 @@
22

33
<PropertyGroup>
44
<TargetFrameworks>netstandard2.0;net5.0;net6.0</TargetFrameworks>
5-
<VersionPrefix>1.6.1.109</VersionPrefix>
5+
<VersionPrefix>1.6.1.110</VersionPrefix>
66
<VersionSuffix>custom</VersionSuffix>
7-
<PackageVersion>1.6.1.109-custom</PackageVersion>
8-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
9-
<FileVersion>1.6.1.109</FileVersion>
7+
<PackageVersion>1.6.1.110-custom</PackageVersion>
8+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
9+
<FileVersion>1.6.1.110</FileVersion>
1010
<SignAssembly>true</SignAssembly>
1111
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
1212
<GenerateDocumentationFile>true</GenerateDocumentationFile>

‎metrics/Streamiz.Kafka.Net.Metrics.Prometheus/Streamiz.Kafka.Net.Metrics.Prometheus.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,11 @@
22

33
<PropertyGroup>
44
<TargetFrameworks>netstandard2.0;net5.0;net6.0</TargetFrameworks>
5-
<VersionPrefix>1.6.1.109</VersionPrefix>
5+
<VersionPrefix>1.6.1.110</VersionPrefix>
66
<VersionSuffix>custom</VersionSuffix>
7-
<PackageVersion>1.6.1.109-custom</PackageVersion>
8-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
9-
<FileVersion>1.6.1.109</FileVersion>
7+
<PackageVersion>1.6.1.110-custom</PackageVersion>
8+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
9+
<FileVersion>1.6.1.110</FileVersion>
1010
<SignAssembly>true</SignAssembly>
1111
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
1212
<GenerateDocumentationFile>true</GenerateDocumentationFile>

‎serdes/Streamiz.Kafka.Net.SchemaRegistry.SerDes.Avro/Streamiz.Kafka.Net.SchemaRegistry.SerDes.Avro.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,11 @@
1919
<PackageIconUrl>https://raw.githubusercontent.com/LGouellec/kafka-streams-dotnet/master/resources/logo-kafka-stream-net.png</PackageIconUrl>
2020
<SignAssembly>true</SignAssembly>
2121
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
22-
<VersionPrefix>1.6.1.109</VersionPrefix>
22+
<VersionPrefix>1.6.1.110</VersionPrefix>
2323
<VersionSuffix>custom</VersionSuffix>
24-
<PackageVersion>1.6.1.109-custom</PackageVersion>
25-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
26-
<FileVersion>1.6.1.109</FileVersion>
24+
<PackageVersion>1.6.1.110-custom</PackageVersion>
25+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
26+
<FileVersion>1.6.1.110</FileVersion>
2727
</PropertyGroup>
2828

2929
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

‎serdes/Streamiz.Kafka.Net.SchemaRegistry.SerDes.Json/Streamiz.Kafka.Net.SchemaRegistry.SerDes.Json.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -19,11 +19,11 @@
1919
<PackageIconUrl>https://raw.githubusercontent.com/LGouellec/kafka-streams-dotnet/master/resources/logo-kafka-stream-net.png</PackageIconUrl>
2020
<SignAssembly>true</SignAssembly>
2121
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
22-
<VersionPrefix>1.6.1.109</VersionPrefix>
22+
<VersionPrefix>1.6.1.110</VersionPrefix>
2323
<VersionSuffix>custom</VersionSuffix>
24-
<PackageVersion>1.6.1.109-custom</PackageVersion>
25-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
26-
<FileVersion>1.6.1.109</FileVersion>
24+
<PackageVersion>1.6.1.110-custom</PackageVersion>
25+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
26+
<FileVersion>1.6.1.110</FileVersion>
2727
</PropertyGroup>
2828

2929
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

‎serdes/Streamiz.Kafka.Net.SchemaRegistry.SerDes.Protobuf/Streamiz.Kafka.Net.SchemaRegistry.SerDes.Protobuf.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -12,11 +12,11 @@
1212
<PackageIconUrl>https://raw.githubusercontent.com/LGouellec/kafka-streams-dotnet/master/resources/logo-kafka-stream-net.png</PackageIconUrl>
1313
<SignAssembly>true</SignAssembly>
1414
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
15-
<VersionPrefix>1.6.1.109</VersionPrefix>
15+
<VersionPrefix>1.6.1.110</VersionPrefix>
1616
<VersionSuffix>custom</VersionSuffix>
17-
<PackageVersion>1.6.1.109-custom</PackageVersion>
18-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
19-
<FileVersion>1.6.1.109</FileVersion>
17+
<PackageVersion>1.6.1.110-custom</PackageVersion>
18+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
19+
<FileVersion>1.6.1.110</FileVersion>
2020
</PropertyGroup>
2121

2222
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

‎serdes/Streamiz.Kafka.Net.SchemaRegistry.SerDes/Streamiz.Kafka.Net.SchemaRegistry.SerDes.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -14,11 +14,11 @@
1414
<PackageIconUrl>https://raw.githubusercontent.com/LGouellec/kafka-streams-dotnet/master/resources/logo-kafka-stream-net.png</PackageIconUrl>
1515
<SignAssembly>true</SignAssembly>
1616
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
17-
<VersionPrefix>1.6.1.109</VersionPrefix>
17+
<VersionPrefix>1.6.1.110</VersionPrefix>
1818
<VersionSuffix>custom</VersionSuffix>
19-
<PackageVersion>1.6.1.109-custom</PackageVersion>
20-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
21-
<FileVersion>1.6.1.109</FileVersion>
19+
<PackageVersion>1.6.1.110-custom</PackageVersion>
20+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
21+
<FileVersion>1.6.1.110</FileVersion>
2222
</PropertyGroup>
2323

2424
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

‎serdes/Streamiz.Kafka.Net.SerDes.CloudEvents/Streamiz.Kafka.Net.SerDes.CloudEvents.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,11 @@
1818
<PackageIconUrl>https://raw.githubusercontent.com/LGouellec/kafka-streams-dotnet/master/resources/logo-kafka-stream-net.png</PackageIconUrl>
1919
<SignAssembly>true</SignAssembly>
2020
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
21-
<VersionPrefix>1.6.1.109</VersionPrefix>
21+
<VersionPrefix>1.6.1.110</VersionPrefix>
2222
<VersionSuffix>custom</VersionSuffix>
23-
<PackageVersion>1.6.1.109-custom</PackageVersion>
24-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
25-
<FileVersion>1.6.1.109</FileVersion>
23+
<PackageVersion>1.6.1.110-custom</PackageVersion>
24+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
25+
<FileVersion>1.6.1.110</FileVersion>
2626
</PropertyGroup>
2727

2828
<PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">

‎test/Streamiz.Kafka.Net.Tests/Streamiz.Kafka.Net.Tests.csproj

+4-4
Original file line numberDiff line numberDiff line change
@@ -9,11 +9,11 @@
99
<SignAssembly>true</SignAssembly>
1010
<AssemblyOriginatorKeyFile>..\..\key.snk</AssemblyOriginatorKeyFile>
1111
<StartupObject></StartupObject>
12-
<VersionPrefix>1.6.1.109</VersionPrefix>
12+
<VersionPrefix>1.6.1.110</VersionPrefix>
1313
<VersionSuffix>custom</VersionSuffix>
14-
<PackageVersion>1.6.1.109-custom</PackageVersion>
15-
<AssemblyVersion>1.6.1.109</AssemblyVersion>
16-
<FileVersion>1.6.1.109</FileVersion>
14+
<PackageVersion>1.6.1.110-custom</PackageVersion>
15+
<AssemblyVersion>1.6.1.110</AssemblyVersion>
16+
<FileVersion>1.6.1.110</FileVersion>
1717
</PropertyGroup>
1818

1919
<ItemGroup>

0 commit comments

Comments
 (0)