Skip to content

Commit 28e046e

Browse files
emaalberoemaalbero
committed
restored CreateTasks original code
1 parent 08c11cb commit 28e046e

File tree

10 files changed

+42
-44
lines changed

10 files changed

+42
-44
lines changed

‎core/Processors/Internal/TaskManager.cs

+6-8
Original file line numberDiff line numberDiff line change
@@ -70,16 +70,14 @@ public void CreateTasks(ICollection<TopicPartition> assignment)
7070
foreach (var partition in new List<TopicPartition>(assignment))
7171
{
7272
var taskId = builder.GetTaskIdFromPartition(partition);
73-
if (activeTasks.ContainsKey(taskId))
73+
if (!activeTasks.ContainsKey(taskId))
7474
{
75-
activeTasks[taskId].Close();
76-
activeTasks.TryRemove(taskId, out _);
75+
if (tasksToBeCreated.ContainsKey(taskId))
76+
tasksToBeCreated[taskId].Add(partition);
77+
else
78+
tasksToBeCreated.Add(taskId, new List<TopicPartition> { partition });
79+
partitionsToTaskId.TryAdd(partition, taskId);
7780
}
78-
if (tasksToBeCreated.ContainsKey(taskId))
79-
tasksToBeCreated[taskId].Add(partition);
80-
else
81-
tasksToBeCreated.Add(taskId, new List<TopicPartition> { partition });
82-
partitionsToTaskId.TryAdd(partition, taskId);
8381
}
8482

8583
if (tasksToBeCreated.Count > 0)

‎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.108</VersionPrefix>
22+
<VersionPrefix>1.6.1.109</VersionPrefix>
2323
<VersionSuffix>custom</VersionSuffix>
24-
<PackageVersion>1.6.1.108-custom</PackageVersion>
25-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
26-
<FileVersion>1.6.1.108</FileVersion>
24+
<PackageVersion>1.6.1.109-custom</PackageVersion>
25+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
26+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
5+
<VersionPrefix>1.6.1.109</VersionPrefix>
66
<VersionSuffix>custom</VersionSuffix>
7-
<PackageVersion>1.6.1.108-custom</PackageVersion>
8-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
9-
<FileVersion>1.6.1.108</FileVersion>
7+
<PackageVersion>1.6.1.109-custom</PackageVersion>
8+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
9+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
5+
<VersionPrefix>1.6.1.109</VersionPrefix>
66
<VersionSuffix>custom</VersionSuffix>
7-
<PackageVersion>1.6.1.108-custom</PackageVersion>
8-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
9-
<FileVersion>1.6.1.108</FileVersion>
7+
<PackageVersion>1.6.1.109-custom</PackageVersion>
8+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
9+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
22+
<VersionPrefix>1.6.1.109</VersionPrefix>
2323
<VersionSuffix>custom</VersionSuffix>
24-
<PackageVersion>1.6.1.108-custom</PackageVersion>
25-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
26-
<FileVersion>1.6.1.108</FileVersion>
24+
<PackageVersion>1.6.1.109-custom</PackageVersion>
25+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
26+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
22+
<VersionPrefix>1.6.1.109</VersionPrefix>
2323
<VersionSuffix>custom</VersionSuffix>
24-
<PackageVersion>1.6.1.108-custom</PackageVersion>
25-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
26-
<FileVersion>1.6.1.108</FileVersion>
24+
<PackageVersion>1.6.1.109-custom</PackageVersion>
25+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
26+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
15+
<VersionPrefix>1.6.1.109</VersionPrefix>
1616
<VersionSuffix>custom</VersionSuffix>
17-
<PackageVersion>1.6.1.108-custom</PackageVersion>
18-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
19-
<FileVersion>1.6.1.108</FileVersion>
17+
<PackageVersion>1.6.1.109-custom</PackageVersion>
18+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
19+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
17+
<VersionPrefix>1.6.1.109</VersionPrefix>
1818
<VersionSuffix>custom</VersionSuffix>
19-
<PackageVersion>1.6.1.108-custom</PackageVersion>
20-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
21-
<FileVersion>1.6.1.108</FileVersion>
19+
<PackageVersion>1.6.1.109-custom</PackageVersion>
20+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
21+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
21+
<VersionPrefix>1.6.1.109</VersionPrefix>
2222
<VersionSuffix>custom</VersionSuffix>
23-
<PackageVersion>1.6.1.108-custom</PackageVersion>
24-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
25-
<FileVersion>1.6.1.108</FileVersion>
23+
<PackageVersion>1.6.1.109-custom</PackageVersion>
24+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
25+
<FileVersion>1.6.1.109</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.108</VersionPrefix>
12+
<VersionPrefix>1.6.1.109</VersionPrefix>
1313
<VersionSuffix>custom</VersionSuffix>
14-
<PackageVersion>1.6.1.108-custom</PackageVersion>
15-
<AssemblyVersion>1.6.1.108</AssemblyVersion>
16-
<FileVersion>1.6.1.108</FileVersion>
14+
<PackageVersion>1.6.1.109-custom</PackageVersion>
15+
<AssemblyVersion>1.6.1.109</AssemblyVersion>
16+
<FileVersion>1.6.1.109</FileVersion>
1717
</PropertyGroup>
1818

1919
<ItemGroup>

0 commit comments

Comments
 (0)