Click here to Skip to main content
14,385,176 members
Rate this:
Please Sign up or sign in to vote.
See more:
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).

<pre>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","sample-consumer" },
                {"group.id","JavaInUseGroup" },
                {"bootstrap.servers", "localhost:9092" },
                { "enable.auto.commit", "false" }

            };

        //using (var consumer = new Consumer<Null, string>(config, null, new StringSerializer(Encoding.UTF8)))
        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);
            }
        }


    }


}




What I have tried:

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.Consumer2[TKey,TValue]..ctor (System.Collections.Generic.IEnumerable1[T] config,
  Confluent.Kafka.Serialization.IDeserializer1[T] keyDeserializer, Confluent.Kafka.Serialization.IDeserializer`1[T] valueDeserializer) (at <700d5bbe3b974ce5aed001c82b789f6a>:0) KafkaConsumer.Start () (at Assets/KafkaConsumer.cs:26)
Posted
Comments
Rob Philpott 15-Feb-19 9:41am
   
Well, the error states this: 'Error while loading librdkafka.dll or its dependencies from Assets/librdkafka.dll'. Is that DLL there, in a folder called Assets? It's probably an unmanaged thing used by confluent.Kafka.dll

This content, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)




CodeProject, 503-250 Ferrand Drive Toronto Ontario, M3C 3G8 Canada +1 416-849-8900 x 100