1回答
我使用Kafka头来传递用于日志记录的关联id，然后由Kafka拦截器使用它放入MDC。我的问题是头部信息到底存储在哪里，我的postgres DB没有任何用于存储消息头部信息的列，那么kafka将这些信息存储在哪里呢？它使用哪个数据存储区？下面是我的kafka_messag
浏览 21提问于2021-09-02得票数 0
1回答
卡夫卡活页夹的源代码来自当定义的函数如下所示时，示例应用程序可以正常工作。该应用程序可以很好地转换并将一条avro消息转换为kafka主题，并按其应有的方式工作。，用于基于报头的额外的下游处理。我无法访问引导版本中的标题。2.1.12。
我根据云流文档中的
浏览 5提问于2020-04-17得票数 0
我希望使用Avro来序列化我的Kafka消息的数据，并希望将其与Avro模式存储库一起使用，这样我就不必在每条消息中都包含该模式。在Kafka中使用Avro似乎是一件很受欢迎的事情，许多博客/ Stack Overflow问题/用户组等都提到将Schema Id与消息一起发送，但我找不到一个实际的示例来说明它应该去哪里。我认为
浏览 71提问于2015-07-03得票数 21
回答已采纳
2回答
我有两个非常简单的春云流应用程序。Service3，消息生产者，通过绑定器-卡夫卡向消费者Service4发送消息。
我用春云雪橇来追踪它们之间的跨度。但是在zipkin服务器中，只有Service3中的spans可用。Service4没有span显示。org.springframework.cloud:spring-cloud-sleuth-stream') compile('org.springframework.cloud:spring-cloud-stream
浏览 9提问于2017-02-22得票数 0
我正在尝试发布一些消息，以及一些自定义的标题，到kafka。但我无法在Landoop Kafka UI中看到这些标题细节。有人能告诉我标题部分在kafka Landoop UI中的位置吗？
浏览 21提问于2019-11-04得票数 0
我刚刚开始对Kafka的探索，我无法理解kafka中什么是键值的需要，因为我们也可以直接发送消息，像JMS这样的单个字符串。通过指定键可以从记录中获取值吗？(我正在将它与JMS中的选择器进行比较，因此我们可以在此基础上过滤消息)。
我们如何通过消息传递标头？是否有可能只发送带有标题而不是键值对的消息？
浏览 3提问于2019-09-22得票数 0
回答已采纳
假设我从kafka生产者向kafka消费者发送一些消息，那么它将存储在哪里？有没有用来存储消息的数据库？消息存储了多长时间？
有没有人能解释一下。
浏览 0提问于2018-04-23得票数 6
回答已采纳
对于其中一个用例，我需要将数据从一个集群上的Kafka主题(引导: bootstrap1，主题: topic1)移到不同集群中具有不同名称的主题(引导: bootstrap2，主题: topic2)。有另一个用例，在同一个项目中，最适合水槽，我需要使用相同的水槽管道为这个用例-虽然有其他的选择从卡夫卡复制到卡夫卡。
我尝试了下面的吐露和结果，如在每个选项中提到的。作为源代码(bootstrap1，topic1)和kafka作为接收器(bootstrap
浏览 5提问于2021-03-13得票数 0
1回答
我计划在Informatica中使用Kafka数据对象。我想每5分钟通过Informatica从Kafka读取数据。我很少有疑问，卡夫卡如何认识到当前的偏移，从它必须加载。我们可以设置一个主题的偏移量，Informatica需要从它加载Kafka数据对象中的增量或更改的数据吗？我找到了以下答案，请您纠正我的确切过程: 1)动物园管理员是否将当前偏移量存储到加载数据的位置。2)若要读取上次提交
浏览 2提问于2017-06-30得票数 0
3回答
我正在尝试使用Spring Cloud Stream来集成Kafka。正在编写的消息是Java POJO，虽然它的工作方式与预期一样(消息正在写入主题，我可以使用消费者应用程序读取)，但消息的开头添加了一些未知字符，这在尝试集成Kafka Connect以接收主题中的消息时会造成麻烦在默认设置下，这是推送到Kafka的消息：
浏览 1提问于2017-11-21得票数 3
回答已采纳
我正在使用SpringCloudStream3.2.2为kafka主题生成云事件消息。根据Cloud规范，在使用kafka时，标头应该使用"ce_“前缀。setSpecVersion("1.0") .build(),在我的配置中，我的绑定器设置为<
浏览 7提问于2022-04-11得票数 0
我们有kafka流应用程序。Producer在将kafka消息发送到Kafka流媒体应用之前，会在消息中添加头部。在Kafka流媒体应用中，我们使用AbstractProcessor和context.forward(null, Optional.of(event));将消息转发到另一个主题。 但是报头正在丢失。我希望标题是从输入消息到输出主题。 ProcessorContext接口。headers()方法返回当前输入
浏览 5提问于2020-06-10得票数 0
回答已采纳
当我在管道中创建一个流，并且它开始消费一个主题时，它没有出现在我的主题的活动consmidores中，我该怎么做才能让它出现在那里呢？我是如何创建流的SELECT pipeline_kafka.consume_begin('topicSummaryDevice', 'pipeli
浏览 1提问于2017-04-26得票数 0
我使用redis作为spring分布式env的消息存储库。我将消息头设置如下，在检查在处理器中接收到的消息时，它只显示id和时间戳。发送时的标头
[Headers={colu
浏览 2提问于2014-08-01得票数 2
回答已采纳
据我所知，处理Kafka流的状态在内存、磁盘或Kafka主题中都是本地的，因为所有的输入数据都来自一个分区，其中所有的消息都是由一个定义的值键控的。大多数情况下，计算可以在不知道其他处理器的状态的情况下完成。如果是这样的话，您有另一个Streams实例来计算结果。如图所示：Flink到底在哪里存储它的状态？Flink是否也可以
浏览 0提问于2019-02-10得票数 3
我有需要重用的spring集成流。@Bean return IntegrationFlows.from("kafkaRequestChannel")
.handle(Kafkaget(IntegrationMessageHe
浏览 0提问于2017-09-29得票数 1
回答已采纳
2回答
所以他们中的一个会得到问题，然后做一些事情，然后改变这个问题的状态。其他可能涉及这一问题的应用程序应该获得新的信息。这种情况一直持续到问题达到最终结束状态为止。问题在于必须映射问题，因为这些应用程序并不都支持相同的数据格式。
谢谢你的建议
浏览 2提问于2017-10-11得票数 1
回答已采纳
:1.5.19场景1:结论：与混合卡夫卡版本，没有数据，消费者和生产者工作良好。场景2:
添加datadog后，消息不会传递给使用者，在使用者端我们可以看到异常: o
浏览 6提问于2021-08-31得票数 0
1回答
我正在构建一个处理器应用程序，它将使用字符串键来消耗原始数据，有时还会使用Kafka主题的空有效负载。我想为另一个主题生成一个字符串键和空有效载荷(称为Kafka中的墓碑)。为了在消息上使用原始头，我需要输出一个byte[]，但是如果我将KafkaNull.INSTANCE编码成一个byte[]，它将从字面上输出一个对象哈希码的字符串。如果我试图发送一个byte[]以外的任何东西，我就不能使用原始头。
正确的
浏览 2提问于2017-03-22得票数 1
回答已采纳
云服务器
ICP备案
腾讯会议
云直播
对象存储
腾讯云开发者
