I am trying to run a code sample of Kafka in unity environment and for this reason, I created a consumer client (Code given below).
using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using Confluent.Kafka;
using Confluent.Kafka.Serialization;
using System.Text;
public class KafkaConsumer : MonoBehaviour
{
// Use this for initialization
void Start ()
{
/*
* The consumer application will then pick the messages from the same topic and write them to console output.
* The process to create the consumer application is also very simple.
*/
var config = new Dictionary<string, object>
{
{ "group.id","JavaInUseGroup" },
{ "bootstrap.servers", "localhost:9092" },
{ "enable.auto.commit", "false" }
};
using (var consumer = new Consumer<Null, string>(config, null, new StringDeserializer(Encoding.UTF8)))
{
consumer.Subscribe(new string[] { "javainuse-topic" });
consumer.OnMessage += (_, msg) =>
{
//Console.WriteLine($"Topic: {msg.Topic} Partition: {msg.Partition} Offset :{msg.Offset} {msg.Value}");
Debug.Log($"Topic: {msg.Topic} Partition: {msg.Partition} Offset :{msg.Offset} {msg.Value}");
consumer.CommitAsync(msg);
};
while (true)
{
consumer.Poll(100);
}
}
}
}
In order to execute the above code sample I have also added confluent.Kafka dll
into my project asset folder. but whenever I run my unity game it throws an error:Win32Exception: The specified module could not be found.
Rethrow as InvalidOperationException: Error while loading
librdkafka.dll or its dependencies from Assets/librdkafka.dll. Check
the directory exists, if not check your deployment process. You can
also load the library and its dependencies by yourself before any call
to Confluent.Kafka Confluent.Kafka.Impl.LibRdKafka.Initialize
(System.String userSpecifiedPath) (at
<700d5bbe3b974ce5aed001c82b789f6a>:0) Confluent.Kafka.Consumer..ctor
(System.Collections.Generic.IEnumerable1[T] config) (at
<700d5bbe3b974ce5aed001c82b789f6a>:0)
Confluent.Kafka.Consumer
2[TKey,TValue]..ctor
(System.Collections.Generic.IEnumerable1[T] config,
Confluent.Kafka.Serialization.IDeserializer
1[T] keyDeserializer,
Confluent.Kafka.Serialization.IDeserializer`1[T] valueDeserializer)
(at <700d5bbe3b974ce5aed001c82b789f6a>:0) KafkaConsumer.Start () (at
Assets/KafkaConsumer.cs:26)
As the error states that there is dependancy problem so i have also copied these dll in assets/librdkafka/x64 folder
- librdkafka
librdkafkacpp
msvcr120
- zlib
Now the problem is, my project get stuck whenever i try to play it.
Remember: I have downloaded all these dll through nuget in vs 2017. Then i bring these dll into unity.
See Question&Answers more detail:
os 与恶龙缠斗过久,自身亦成为恶龙;凝视深渊过久,深渊将回以凝视…