infer generic type in clients

Author: dineeno

kafka-java-console-sample/src/main/java/com/eventstreams/samples/ConsumerRunnable.java

@@ -41,7 +41,7 @@ public class ConsumerRunnable implements Runnable {
 
     public ConsumerRunnable(Map<String, Object> consumerConfigs, String topic) {
         // Create a Kafka consumer with the provided client configuration
-        kafkaConsumer = new KafkaConsumer<String, String>(consumerConfigs);
+        kafkaConsumer = new KafkaConsumer<>(consumerConfigs);
 
         // Checking for topic existence before subscribing
         List<PartitionInfo> partitions = kafkaConsumer.partitionsFor(topic);

kafka-java-console-sample/src/main/java/com/eventstreams/samples/ProducerRunnable.java

@@ -45,7 +45,7 @@ public ProducerRunnable(Map<String, Object> producerConfigs, String topic) {
         this.topic = topic;
 
         // Create a Kafka producer with the provided client configuration
-        kafkaProducer = new KafkaProducer<String, String>(producerConfigs);
+        kafkaProducer = new KafkaProducer<>(producerConfigs);
 
         try {
             // Checking for topic existence.
@@ -74,7 +74,7 @@ public void run() {
 
                 try {
                     // If a partition is not specified, the client will use the default partitioner to choose one.
-                    ProducerRecord<String, String> record = new ProducerRecord<String, String>(topic,key,message);
+                    ProducerRecord<String, String> record = new ProducerRecord<>(topic,key,message);
 
                     // Send record asynchronously
                     Future<RecordMetadata> future = kafkaProducer.send(record);