如何在kafka中禁用报头
任何选项，我只能使用消息内容，留下报头，以便节省时间，通过网络传输报头和反序列化他们在消费者。感谢你的帮助。
共有1个答案
每条消息都是一条带有标题的记录（从Kafka0.11开始）。
length: varint
attributes: int8
bit 0~7: unused
timestampDelta: varint
offsetDelta: varint
keyLength: varint
key: byte[]
valueLen: varint
value: byte[]
Headers => [Header]
记录标题
headerKeyLength: varint
headerKey: String
headerValueLength: varint
Value: byte[]
即使忽略反序列化，它们仍将作为记录的TCP数据包主体的一部分通过有线发送。
-
问题内容： 使用杰克逊2.1，如何禁用错误消息似乎要禁用的消息？ 我以为这只是世界上最简单的事情，但是该死了，它太迟了，我还没有找到一个简单的教程或任何特别明显的东西。？他们为什么要使它如此直观，然后使错误消息看起来如此简单？ 尽管我 确实 喜欢该错误消息，但我的意思是，它比NPE更好。 我假设有一种使用注释的方法-但是我根本不希望将它们用于我正在做的简单工作！ 问题答案： 我相信，您可以按班级或
-
问题内容： 我创建了一个swings应用程序，并且GUI上有一个“开始”按钮。我希望每当我单击该“开始”按钮时，都应禁用开始按钮，并启用“停止”按钮。 为此，我在“开始”按钮的“ ActionPeformed（…）”方法中编写了以下代码 但是以上代码并未在GUI上产生所需的影响。 上面的代码对我想要做的正确吗？ 它也不能与“ repaint（）”一起使用。 编辑： 代码很长，所以我不能粘贴所有代码
-
以下是我的情况： 我们有一个Spring cloud Stream 3 Kafka服务连接到同一个代理中的多个主题，但我想基于属性控制连接到特定主题。 每个主题都有自己的活页夹和绑定，但代理对所有人来说都是一样的。 我尝试使用下面的属性禁用绑定（这是我到目前为止找到的唯一解决方案），这适用于StreamListener不接收消息，但与主题的连接和重新平衡仍在发生。 我想知道活页夹级别是否有任何设置
-
问题内容： 当我使用Alamofire两次发送GET请求时，我得到的响应是相同的，但是我期望得到不同的响应。我想知道这是否是由于缓存造成的，如果是这样，我想知道如何禁用它。 问题答案： 迅捷3，alamofire 4 我的解决方案是： 为Alamofire创建扩展： 并使用它：
-
问题内容： 我正在创建应在Tomcat上运行的SOAP服务。 我正在为我的应用程序使用Spring Boot，类似于： 我的网络服务（示例）： 问题： 每当我在webservice类中引发异常时，服务器上都会记录以下消息： ErrorPageFilter：由于响应已提交，因此无法转发到请求[/ services / MyWebservice]的错误页面。结果，响应可能具有错误的状态代码。如果您的应
-
问题内容： 我有这个组成部分： 我希望在输入值为空时禁用按钮。但是上面的代码不起作用。它说： add-item.component.js：78未捕获的TypeError：无法读取未定义的属性“值” 指向。我在这里怎么做错了？我猜测执行方法时可能尚未创建ref 。如果是，那么解决方法是什么？ 问题答案： 使用不是最佳实践，因为它直接读取DOM，最好使用React的。另外，您的按钮不会更改，因为该组件