Hi All, I am new to Kafka and still getting myself acquainted with the product. I have a basic question around using Kafka. I want to store in a Kafka topic, a string value against some keys while a HashMap value against some of the keys. For this purpose, I have created two different producers as below which I instantiate with two different producer instances. Note that I need to create two different producers since I want to use generic types properly, else with a single producer if I want to use the same producer to store a String and Map then I will need to use <String, Object> in the generic types and Object is too generic which I don't want to allow, so defined two different producers...
private static Producer<String, String> basicProducer = null; private static Producer<String, Map> hashProducer = null; Now, if I want to use other streams classes such as KTable or GlobalKTable from where I would read my data, then these classes also requires to define generic types e.g. if I define a GlobalKTable like below then it won't work for HashMap stored against key: private static GlobalKTable<String, String> eventsGTable; So, in order to allow a String as well as Map stored against key in a topic, how should I go about it? Do I need to use <String, Object> as generic types in all definitions and then cast from Object to String or Map as per the type of instance stored in the object?
