此方法可以按时间戳返回偏移量。所以我的问题是->在这两种情况下都提到了什么时间戳？如果是，它的时间戳是KafkaRecord吗？->，它可以和message.timestamp.type=CreateTime一起工作吗？
浏览 52提问于2021-02-11得票数 0
回答已采纳
我们可以为kafka ProducerRecord构造函数指定时间戳。ProducerRecord(String topic, Integer partition, Long timestamp, K key, V value, Iterable<Header> headers)
这个时间放大器的目的是什么
浏览 2提问于2021-08-31得票数 0
回答已采纳
当我在生产环境中更改某些内容时，我总是在时间戳中将“分钟”增加1，例如：=>
<script src="js/some_javascriptfile.js?我的问题是:是否某个浏览器忽略了我对日期时间戳</e
浏览 3提问于2020-08-14得票数 3
我想在生产中提供一个特定的js文件(heroku)，而不需要时间戳。我可以单独提供文件，但它有时间戳，但我不想要。原因是我想让其他网站访问这个文件。<%= javascript_include_tag 'ca4me', 'data-turbolinks-track' => true, :cache => false %>
application.js// This is a manife
浏览 1提问于2014-05-30得票数 1
回答已采纳
1回答
我想提取嵌入每条消息的时间戳，并将它们作为json有效负载发送到我的数据库中。
我想得到以下三个时间戳。事件-时间： The point in time when an event or data record occurred, i.e. was originally created “by the source
浏览 0提问于2018-03-05得票数 5
回答已采纳
对于这个数据的每个“实例”，我都有一个时间戳。我可以检测我从中获取数据的机器是“正在生成”还是“未生成”，这是通过位于它自己的静态类中的自定义平面映射函数来完成的。我想计算一下这台机器生产/不生产的时间。我目前的方法是在两个普通列表中收集生产和非生产时间戳。对于数据的每个“实例”，我通过从最早的时间戳中减去最新的时间戳来计算当前的生产&
浏览 0提问于2018-10-30得票数 1
我正在使用Kafka-Net nuget软件包为卡夫卡的生产和消费做一个基本的POC。消息以正确的偏移量和有效负载附加到主题中，它们只有一个空白的时间戳。
浏览 1提问于2019-03-06得票数 1
假设我有一个生产者，它为卡夫卡发送每一个时间戳的数据。使用者获取时间戳t的数据的条件是，时间戳t的数据是从所有生产者收到的。
卡夫卡让消费者做这样的检查吗？或者卡夫卡对这样的问题有什么策略吗？
浏览 0提问于2017-10-20得票数 0
回答已采纳
在表单中，我可以设置闹钟，选择日期和时间。我只想选择这个date+time的unix时间戳。在我的电脑里，它工作得很好。但在生产服务器中，以秒为单位的时间戳是6小时前的。这是一段js代码：
浏览 3提问于2016-02-27得票数 2
我想在kafka producer中跟踪记录时间戳:何时由生产者发送记录，以及代理何时接收ack和存储记录(在ack时间戳上)。每个记录的头中都有字符串id。RecordMetadata metadata, Exception exception) {在onAcknowledgement中，我有RecordMetadata，可以获得record时间戳或者有更好的方法来跟踪记录的发送/接收时间戳？
不，我不能使用
浏览 4提问于2021-08-30得票数 2
在Wicket应用程序中，我们可以使用标准HTML方式指定标记中资源的URL，如下所示： + "/js/jquery-1.11.3.mi
浏览 0提问于2016-06-04得票数 0
回答已采纳
至少一次语义学:如果生产者收到一个确认(ack)从卡夫卡经纪人和acks=all，这意味着消息已经写了一次准确的卡夫卡主题。然而，如果生产者超时或收到错误，它可能会重试发送消息，假设消息没有写到Kafka主题。我知道时间戳是根据从生产者发送消息的时间来设置的。如果生产者执行重试，这两条消息是否具有相同的时间戳？
浏览 2提问于2020-07-18得票数 1
回答已采纳
'></script>");http://code.jquery.com/jquery-1.9.1.js?_=1366193092174jQuery("body").append("<script src='http:/
浏览 0提问于2013-04-17得票数 2
在kafka-python库的正式文档中，对于已消耗的记录.timestamp属性分配的值实际上没有任何信息。
浏览 4提问于2022-07-08得票数 0
如果Kafka配置了Log-Append Time，那么代理是否会覆盖消息时间戳，而不管生产者/流设置了什么时间戳？从中，我得到的印象是，CreateTime有点不可靠--有时只转发时间戳(例如，在使用context.forward()时)，有时被覆盖(例如，在使用puntuate()时)。因此，我想知道在设置消息时间戳(即覆盖流设置的时间戳)时，Log-Append Time是否优先？
浏览 4提问于2022-11-02得票数 1
回答已采纳
我在一张表上有一个时间戳，格式是“2020-09-29 06:30:30”。我需要从这个时间戳列中得到一个名为"ProductionDate“的新行。如果时间戳分钟< 06:30:00.000，我需要回滚到以前的日期作为生产日期。我想得到一个生产日期，如果时间戳下降在这个24小时的范围以上，给我"2020-09-29“。
我目前正在使用下面的命令获取日期，但它将离开时间<e
浏览 3提问于2020-10-01得票数 0
回答已采纳
之所以需要这种机制，是因为这里的生产者不是使用者，也不是数据库支持的，这适用于来自TCP或UDP通道等源的数据流。如果KafkaProducer已经发送了一条信息，并且它被持久化给了卡夫卡经纪人，但是在生产者收到确认之前，生产者就被杀死了，会发生什么呢？如果在重新启动后再次发送，它不会复制吗？通过幂等生成器，我看到了生产者PID的用法，但是同样的PID在重新启动时会被重用吗？
卡夫卡是如何在其重新启动的情况下唯一地识别一个生产者的?如果它不这样做，如何实现一种具有幂等效应的退避机制？
浏览 3提问于2019-08-21得票数 2
云服务器
ICP备案
对象存储
腾讯会议
实时音视频
腾讯云开发者
