
You may be missing the librdkafka.dll file for your system. KafkaStarted = I needed to do the same thing and recently figured it out. Log( "Kafka - Received Expection: " + ex. Ensure the consumer leaves the group cleanly and final offsets are committed. Got message! Decode and put on queue StreamMessage message = ParseStreamMessage. Cancel = true // prevent the process from terminating. Build())ĬancellationTokenSource cts = new CancellationTokenSource() Į. Using ( var c = new ConsumerBuilder( config). Now, // unique group, so each listener gets all messages BootstrapServers = "localhost:9092 ",ĪutoOffsetReset = AutoOffsetReset. GroupId = "c#test-consumer-group " + DateTime. Public readonly ConcurrentQueue _queue = new ConcurrentQueue() ĭebug. This gives the first type of error result described above.Ĭan anyone please help me with installing Kafka for Unity? I have then tried to build the source and copy the relevant DLL's manually, and tried the same with the nuget release version. This did not seem to work and had the second type of error result described above. I have tried installing the latest release (1.3.0) from nuget (using the UnityPackage ' NuGetForUnity').

Or if I install the System.Memory version that comes with the Kafka NuGet dependency, I get errors all over the place of Unity's own method/class references no longer being found. However I either get errors such as this one:Įrror: Could not load signature of `1:DeserializeAsync due to: Could not load file or assembly 'System.Memory, Version=4.0.1.0, Culture=neutral, PublicKeyToken=cc7b13ffcd2ddd51' or one of its dependencies. This version requires the latest VRCSDK If you are updating from


#87: Support for Udon's new OnVariableChange events via FieldChangeCallback.
