Kafka-Client-Dotnet 1.0.0

Kafka-Client-Dotnet

A kafka library for process documents from queue, note that this project is a not final project, instead is a library that will be used and implemented on final project

Pack it

dotnet pack

Using it

The main scope for this project is keep the kafka connection and process consumed documents. You must implement two interfaces for use it.

Wrapper

the wrapper mut be implement for a custom mappinb gtom kafka document.

The follow is a example of implementation of wrapper, note that you should implement IWrapper interface:

using System;
using System.Collections.Generic;
using PrintQueue.Implementations;

namespace PrintQueue.Wrappers {
	public class DefaultWrapper : IWrapper {

		/**	Port Name	*/
		public String port_name { get; set; }
		/**	Printer Name	*/
		public String printer_name { get; set; }
		
		public String GetPortName() {
			return port_name;
		}
		public String GetPrinterName() {
			return printer_name;
		}
	}
}

When IWrapper is implemented is mandatory implement two methods:

public String GetPortName() {
	return port_name;
}
public String GetPrinterName() {
	return printer_name;
}

Consumer

The consumer or callback is used for implement two actions:

• GetWrapper: Is called from service and hope a IWrapper implementation to process. If the return is null then the ProcessDocument is not called
• ProcessDocument: After get the wrapper, the service call this method for process the document. You should implement here your custom action like print a document or anything.

See the example here:

using System;
using System.Collections.Generic;
using PrintQueue.Implementations;
using PrintQueue.Wrappers;
using System.Text.Json;

namespace PrintQueue.Clients {
	public class DefaultConsumer : IConsumer {

		/** Get a object converted from value	*/
		public IWrapper GetWrapper(String key, byte[] value) {
			IWrapper wrapper = null;
			if(key.Equals("document")) {
            	Document printDocument = JsonSerializer.Deserialize<Document>(value);
            	Console.WriteLine("Document: " + printDocument.invoice.document_no);
				wrapper = printDocument;
            } else if(key.Equals("report")) {
            	Report printReport = JsonSerializer.Deserialize<Report>(value);
            	Console.WriteLine("Report: " + printReport.document_type);
				wrapper = printReport;
            } else if(key.Equals("setup")) {
            	Setup printSetup = JsonSerializer.Deserialize<Setup>(value);
            	Console.WriteLine("Setup: " + printSetup.type); 
				wrapper = printSetup;
            } else {
            	Console.WriteLine("Unsupported type: " + key);    
            }
			return wrapper;
		}
		/**	Print Document	*/
		public void ProcessDocument(IWrapper document) {
			Console.WriteLine("Hi: " + document);
		}
	}
}

Final Implementartion

The service can be called from a Main method like is defined the follow:

using System;
using System.Collections.Generic;
using PrintQueue.Implementations;
using PrintQueue.Wrappers;
using System.Text.Json;
using PrintQueue.Kafka;

namespace PrintQueue.Clients {
	public class TestImplementation {

		
        public static void Main(string[] args) {
            if(args == null) {
                throw new Exception("Arguments Not Found");
            }
            //	
            if(args == null || args.Length == 0) {
                throw new Exception("Arguments Must Be: [property file name]");
            }
			DefaultConsumer defaultConsumer = new DefaultConsumer();
            // 
			Service service = new Service(args[0], defaultConsumer);
			service.start();
        }
	}
}