The method timestamp() in the type ProducerRecord<String,String> is not applicable for the arguments (long)
时间: 2024-05-10 11:19:23 浏览: 16
这个错误通常是因为你正在尝试将一个 `long` 类型的值传递给 `ProducerRecord` 的 `timestamp()` 方法,而该方法期望接收一个 `Long` 类型的值。`long` 和 `Long` 是两种不同的数据类型,需要进行类型转换。
你可以尝试使用 `Long.valueOf()` 方法将 `long` 类型的值转换为 `Long` 类型的值,例如:
```
long timestamp = System.currentTimeMillis();
ProducerRecord<String, String> record = new ProducerRecord<>("topic", "key", "value", Long.valueOf(timestamp));
```
这样就可以将 `long` 类型的 `timestamp` 转换为 `Long` 类型,并将其传递给 `ProducerRecord` 的 `timestamp()` 方法。
相关问题
ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, value, timestamp);
这是一个 Kafka 生产者发送消息的代码示例,其中:
- `topic` 表示要发送消息的主题(Topic)
- `key` 表示消息的键(Key),可以为 `null`
- `value` 表示消息的内容(Value)
- `timestamp` 表示消息的时间戳(Timestamp),可以为 `null`
通过创建一个 `ProducerRecord` 对象,并指定相应的参数,然后将该对象发送给 Kafka 生产者,即可发送一条消息到指定主题。
ProducerRecord<String, String> record = new ProducerRecord<>(topicName, "key", "value", timestamp);
这段代码使用 Kafka Producer API 创建一个 ProducerRecord 对象,它包含了将要发送到 Kafka 集群中的消息的相关信息。具体来说,这个对象包含了目标主题的名称、消息的键和值、以及消息的时间戳。
参数说明:
- topicName:消息要发送到的目标主题的名称。
- key:消息的键,可以为 null。如果指定了键,那么 Kafka 会根据键的哈希值将消息分配到不同的分区中。如果没有指定键,则消息会以轮询的方式被发送到各个分区中。
- value:消息的值,即实际要发送的消息内容。
- timestamp:消息的时间戳,可以为 null。如果没有指定时间戳,则 Kafka 会使用当前时间作为消息的时间戳。
创建 ProducerRecord 对象后,你可以使用 Kafka Producer API 的 send() 方法来将消息发送到 Kafka 集群中。
相关推荐
![zip](https://img-home.csdnimg.cn/images/20210720083736.png)
![.pdf](https://img-home.csdnimg.cn/images/20210720083646.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
ORA-06550: line 1, column 70: PLS-00103: Encountered the symbol ")" when expecting one of the following: ( - + case mod new not null <an identifier> continue avg count current exists max min prior sql stddev sum variance execute forall merge time timestamp interval date pipe <an alternatively-quoted string literal with character set specification> <an alternatively
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)