Je reçois ces erreurs lorsque j'essaie d'exécuter ma classe SupplierConsumer
dans eclipse. Voici mon code:Incompatibilité de type: impossible de convertir de Map <String, ConsumerRecords <String, Supplier >> en ConsumerRecords <String, Supplier>
public class SupplierConsumer{
public static void main(String[] args) throws Exception{
String topicName = "SupplierTopic";
String groupName = "SupplierTopicGroup";
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092,localhost:9093");
props.put("group.id", groupName);
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "SupplierDeserializer");
KafkaConsumer<String, Supplier> consumer = new KafkaConsumer<>(props);
consumer.subscribe(Arrays.asList(topicName));
while (true){
ConsumerRecords<String, Supplier> records = consumer.poll(100);
for (ConsumerRecord<String, Supplier> record : records){
System.out.println("Supplier id= " + String.valueOf(record.value().getID()) + " Supplier Name = " + record.value().getName() + " Supplier Start Date = " + record.value().getStartDate().toString());
}
}
}
}
- Incompatibilité de type: ne peut pas convertir
List<String>
-String
, - Incompatibilité de type: ne peut pas convertir
Map<String,ConsumerRecords<String,Supplier>>
àConsumerRecords<String,Supplier>
Où exactement se produisent les erreurs? Marquez la ligne avec un commentaire ou ajoutez une trace de pile minimale. –
1 erreur vient ici consumer.subscribe (Arrays.asList (topicName)); –
et la deuxième erreur est à consumer.poll (100); –