在spring cloud stream kafka binder中访问RecordMetadata：如何指定recordMetadataChannel
我正在使用Spring云流Kafka活页夹编写Kafka生产者和消费者。我想在生产者和消费者中访问以下信息
a） 主题
b）分区
b）偏移
我确实检查了文档，但并没有真正找到在哪里完成这项工作。我在文档中看到的只是指定一个recordMetadataChannel作为生产者/消费者配置的一部分。有人能告诉我这到底是怎么做到的吗？
共有1个答案
发送到该频道的消息头中的RecordMetadata包含该信息。
看这个答案。
-
我感到困惑的是，在向授权服务器发送授权请求时，似乎没有标准的方法来指定访问令牌的受众。 OAuth2将访问令牌指定为不透明字符串；规范中只有一处提到了“观众”，即访问令牌可以是“观众限制的”。许多最近的授权服务器实现似乎产生了JWT访问令牌，JWT指定了受众（aud）声明。 据我所知：-Auth0使用“audience”参数-Connect2id使用“resource”参数-Identity Se
-
问题内容： 我试图在我的Angular项目中将keyup事件附加到指令。这是指令： 这是模板中的html： 我想在链接函数中访问并将keyup事件附加到它。我知道我可以用jQuery来获得它，但是那不是Angular的方法。从dom中获取该元素的正确方法是什么？ 问题答案： 您可以使用Angular’ ‘ 方法轻松完成此操作： 实时示例：http：//jsfiddle.net/cherniv/S7
-
我想在生成一条发送给Kafka主题的消息后，获取偏移量和分区信息。我通读了spring cloud stream kafka绑定文档，发现这可以通过fecting RECORD\u元数据kafka头来实现。 来自Spring文档：(https://cloud.spring.io/spring-cloud-static/spring-cloud-stream-binder-kafka/3.0.0.R
-
此类的目的是模拟二进制搜索树的功能。在下面的代码中，我试图将它从一个结构和一堆函数改编成一个包装类，称为BST。但是，我不确定的一件事是如何从节点结构中访问“根”。Root当前在BST类中声明。 具体来说，在show函数中。它不像把它和其他函数放在节点中那样简单，因为根需要是唯一的，并且新节点至少被调用一次。Show将不会在当前状态下编译，我不确定从这里开始。
-
问题内容： 首先，我检查了一下，但没有发现涉及我的问题的文章。 如何在angularJS内置指令中访问预定义的js全局变量？ 例如，我在 然后我写一个AngularJS指令： 这实际上是行不通的。 然后我得知我应该使用 所以我在其他地方写了代码： 而且这显然不能正常工作……这就像一个恶性循环。您需要访问预定义的js全局变量，然后需要使用ng-init；为了使用ng-init，您需要访问全局变量。
-
问题内容： 我有这段Java代码： 我想在Kotlin中获得MainActivity对象。自动转换在处中断。 问题答案： 您可以通过使用合格的来获得对Kotlin中对象的引用。例如：