kafka 指定泛型

在 Kafka 中，可以通过指定泛型来定义消息的类型。Kafka 提供了两种泛型参数：键和值。键和值的类型可以是任意的 Java 类型，但在实际使用时，通常会根据具体的业务需求来选择合适的类型。

在创建 Kafka 生产者和消费者时，需要通过泛型参数来指定键和值的类型。例如，创建一个具有整数键和字符串值的 Kafka 生产者可以这样写：

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.IntegerSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

KafkaProducer<Integer, String> producer = new KafkaProducer<>(props);

在这个例子中，`Integer` 是键的类型，`String` 是值的类型。类似地，在创建消费者时，也可以通过指定泛型参数来指定键和值的类型。

这样，在发送消息时，可以使用指定类型的键和值来发送数据到 Kafka，而在消费消息时，也可以使用相应的类型来接收和处理从 Kafka 接收到的数据。