Skip to content
This repository was archived by the owner on Aug 4, 2023. It is now read-only.

Commit 8a0a8d2

Browse files
LiorBanaiLiorBanai
committed
fix #2, fix #3 
1 parent 4b8eb6b commit 8a0a8d2

File tree

5 files changed

+37
-36
lines changed

5 files changed

+37
-36
lines changed

‎Analogy.Implementation.KafkaProvider.Example/Analogy.LogViewer.KafkaProvider.Example.csproj‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -9,9 +9,9 @@
99
</PropertyGroup>
1010

1111
<ItemGroup>
12-
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.6.1" />
13-
<PackageReference Include="Confluent.Kafka" Version="1.2.2" />
14-
<PackageReference Include="librdkafka.redist" Version="1.2.2" />
12+
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.7" />
13+
<PackageReference Include="Confluent.Kafka" Version="1.3.0" />
14+
<PackageReference Include="librdkafka.redist" Version="1.3.0" />
1515
</ItemGroup>
1616

1717
<ItemGroup>

‎Analogy.Implementation.KafkaProvider.Example/AnalogyKafkaExampleDataProvider.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ public void StopReceiving()
4545

4646
}
4747

48-
public Task InitializeDataProviderAsync()
48+
public Task InitializeDataProviderAsync(IAnalogyLogger logger)
4949
{
5050
Producer = new KafkaProducer<AnalogyLogMessage>(kafkaUrl, topic, new KafkaSerializer<AnalogyLogMessage>());
5151
Consumer = new KafkaConsumer<AnalogyLogMessage>(groupId, kafkaUrl, topic);

‎Analogy.Implementation.KafkaProvider.nuspec‎

Lines changed: 28 additions & 27 deletions
Original file line numberDiff line numberDiff line change
@@ -1,31 +1,32 @@
11
<?xml version="1.0"?>
22
<package xmlns="http://schemas.microsoft.com/packaging/2010/07/nuspec.xsd">
3-
<metadata>
4-
<id>Analogy.LogViewer.KafkaProvider</id>
5-
<version>0.1.5</version>
6-
<title>Analogy Log Viewer Kafka Provider</title>
7-
<authors>Lior Banai</authors>
8-
<owners>Lior Banai</owners>
9-
<license type="expression">MIT</license>
10-
<projectUrl>https://github.com/Analogy-LogViewer/Analogy.LogViewer.KafkaProvider</projectUrl>
3+
<metadata>
4+
<id>Analogy.LogViewer.KafkaProvider</id>
5+
<version>1.0.0</version>
6+
<title>Analogy Log Viewer Kafka Provider</title>
7+
<authors>Lior Banai</authors>
8+
<owners>Lior Banai</owners>
9+
<license type="expression">MIT</license>
10+
<projectUrl>https://github.com/Analogy-LogViewer/Analogy.LogViewer.KafkaProvider</projectUrl>
1111
<repository type="git" url="https://github.com/Analogy-LogViewer/Analogy.LogViewer.KafkaProvider"/>
12-
<icon>icon.png</icon>
13-
<requireLicenseAcceptance>false</requireLicenseAcceptance>
14-
<description>Analogy Log Viewer Kafka Provider</description>
15-
<releaseNotes>Initial Proof of concept for creating Kafka data provider (both producer and consumer) For Analogy. See github page</releaseNotes>
16-
<copyright>Copyright 2019 Lior Banai</copyright>
17-
<tags></tags>
18-
<dependencies>
19-
<group targetFramework="netstandard2.0">
20-
<dependency id="Analogy.LogViewer.Interfaces" version="2.1.6.1" />
21-
<dependency id="Confluent.Kafka" version="1.2.2" />
22-
<dependency id="librdkafka.redist" version="1.2.2" />
23-
</group>
24-
</dependencies>
25-
</metadata>
26-
<files>
27-
<file src="Analogy.Implementation.KafkaProvider\bin\Release\netstandard2.0\Analogy.LogViewer.KafkaProvider.dll" target="lib\netstandard2.0\Analogy.LogViewer.KafkaProvider.dll" />
28-
<file src="Analogy.Implementation.KafkaProvider\bin\Release\netstandard2.0\Analogy.LogViewer.KafkaProvider.deps.json" target="lib\netstandard2.0\Analogy.LogViewer.KafkaProvider.deps.json" />
29-
<file src="icon.png" target="" />
30-
</files>
12+
<icon>icon.png</icon>
13+
<requireLicenseAcceptance>false</requireLicenseAcceptance>
14+
<description>Analogy Log Viewer Kafka Provider</description>
15+
<releaseNotes>Initial Proof of concept for creating Kafka data provider (both producer and consumer) For Analogy. See github page</releaseNotes>
16+
<copyright>Copyright 2019 Lior Banai</copyright>
17+
<tags></tags>
18+
<dependencies>
19+
<group targetFramework="netstandard2.0">
20+
<dependency id="Analogy.LogViewer.Interfaces" version="2.1.7" />
21+
<dependency id="Confluent.Kafka" version="1.3.0" />
22+
<dependency id="librdkafka.redist" version="1.3.0" />
23+
</group>
24+
</dependencies>
25+
</metadata>
26+
<files>
27+
<file src="Analogy.Implementation.KafkaProvider\bin\Release\netstandard2.0\Analogy.LogViewer.KafkaProvider.dll" target="lib\netstandard2.0\Analogy.LogViewer.KafkaProvider.dll" />
28+
<file src="Analogy.Implementation.KafkaProvider\bin\Release\netstandard2.0\Analogy.LogViewer.KafkaProvider.deps.json" target="lib\netstandard2.0\Analogy.LogViewer.KafkaProvider.deps.json" />
29+
<file src="Analogy.Implementation.KafkaProvider\bin\Release\netstandard2.0\**\*.*" target="lib\netstandard2.0\" />
30+
<file src="icon.png" target="" />
31+
</files>
3132
</package>

‎Analogy.Implementation.KafkaProvider/Analogy.LogViewer.KafkaProvider.csproj‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@
22

33
<PropertyGroup>
44
<TargetFramework>netstandard2.0</TargetFramework>
5-
<Version>0.1.5</Version>
5+
<Version>1.0.0</Version>
66
<Authors>Lior Banai</Authors>
77
<Company>Lior Banai</Company>
88
<Product>Analogy.Implementation.KafkaProvider</Product>
@@ -11,9 +11,9 @@
1111
</PropertyGroup>
1212

1313
<ItemGroup>
14-
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.6.1" />
15-
<PackageReference Include="Confluent.Kafka" Version="1.2.2" />
16-
<PackageReference Include="librdkafka.redist" Version="1.2.2" />
14+
<PackageReference Include="Analogy.LogViewer.Interfaces" Version="2.1.7" />
15+
<PackageReference Include="Confluent.Kafka" Version="1.3.0" />
16+
<PackageReference Include="librdkafka.redist" Version="1.3.0" />
1717
</ItemGroup>
1818

1919
</Project>

‎Analogy.Implementation.KafkaProvider/AnalogyKafkaDataProvider.cs‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public void StopReceiving()
3636
}
3737

3838

39-
public Task InitializeDataProviderAsync()
39+
public Task InitializeDataProviderAsync(IAnalogyLogger logger)
4040
{
4141
Consumer = new KafkaConsumer<AnalogyLogMessage>(groupId, kafkaUrl, topic);
4242
Consumer.OnMessageReady += Consumer_OnMessageReady;

0 commit comments

Comments
 (0)