Kafka头文件中的勇敢跟踪
Kafka头文件中的"勇敢跟踪"（Brave Tracing）是指在Kafka消息队列系统中实现分布式追踪的一种技术。它通过在消息的生产者和消费者之间插入追踪信息，可以跟踪消息在整个系统中的传递路径和处理过程，从而帮助开发人员定位和解决分布式系统中的问题。
勇敢跟踪的分类：
- 单跨度追踪（Single Span Tracing）：在一个服务内部进行追踪，用于追踪单个服务内的操作。
- 跨度追踪（Span Tracing）：在多个服务之间进行追踪，用于追踪消息在不同服务之间的传递和处理。
勇敢跟踪的优势：
- 故障排查：通过追踪消息的传递路径和处理过程，可以快速定位和解决分布式系统中的故障。
- 性能优化：可以分析消息在系统中的延迟和吞吐量，找出性能瓶颈并进行优化。
- 可视化监控：通过可视化的方式展示消息的传递路径和处理过程，可以实时监控系统的运行状态。
勇敢跟踪的应用场景：
- 分布式系统：在分布式系统中，勇敢跟踪可以帮助开发人员追踪消息在不同服务之间的传递和处理，从而提高系统的可靠性和性能。
- 微服务架构：在微服务架构中，勇敢跟踪可以帮助开发人员跟踪消息在不同微服务之间的传递和处理，从而实现服务间的协同工作。
- 大规模数据处理：在大规模数据处理场景中，勇敢跟踪可以帮助开发人员追踪消息在数据处理流程中的传递和处理，从而提高数据处理的效率和准确性。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云消息队列 Kafka：https://cloud.tencent.com/product/ckafka
- 腾讯云分布式追踪服务 TSW：https://cloud.tencent.com/product/tsw
请注意，以上答案仅供参考，具体的技术实现和产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我正在将Spring应用程序升级到Boot2.6.1、Cloud2021.0.0和CloudStream3.2.1。
这个应用程序有一堆KStreams，如：
@Bean
fun processEvent() =
Function<KStream<ID, EventReceived>, KStream<Id, UpdatedInfo?>> { events ->
...
}
现在，应用程序在启动时崩溃：
Caused by: org.springframework.kafka.Ka
浏览 25提问于2021-12-16得票数 2
回答已采纳
1回答
我有两个弹簧启动微服务使用spring和Kafka。我使用Spring云监视依赖项来进行日志跟踪。在微服务A中，当将事件发布到kafka中的主题时，我将trackId设置为
ExtraFieldPropagation.set("trackId","valueHeader");
在微服务B中，我不会将此值作为行李标头来获取。我得到的是TraceId、SpanID，而不是上面设置的行李元素。
浏览 0提问于2018-06-15得票数 1
我有这个requirments.txt文件： confluent-kafka[avro]==1.1.0 当我运行命令时- $ pip3 install -r requirments.txt 这是我收到的错误： ERROR: Command errored out with exit status 1:
command: /usr/local/opt/python@3.9/bin/python3.9 -u -c 'import io, os, sys, setuptools, tokenize; sys.argv[0] = '"'"'/
浏览 2提问于2021-06-26得票数 1
回答已采纳
2回答
因此，我们在内部使用kafka队列进行一些微服务的通信，也使用zipkin进行分布式跟踪。您是否建议如何在zipkin服务器中引入kafka跟踪以实现可调试性。 我偶然发现了brave-kafka-interceptor，但从提供的最小示例来看，我无法理解kafka。周围有没有其他的例子，或者使用了一些完全不同的库。
浏览 93提问于2021-01-25得票数 2
Spring引导+集成框架在以下方面失败：
Caused by: java.lang.ClassNotFoundException: brave.Tracer
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:418)
试图添加：
<dependency>
<groupId>io.zipkin.brave</groupId>
&l
浏览 41提问于2022-01-13得票数 0
1回答
我正在尝试将Jaeger跟踪集成到K流中。我计划在我的几条最重要的管道上添加追踪，并想知道什么是从一条线到另一条线的好方法？
以下是我到目前为止所拥有的--在流处理管道的开始时，我启动了一个服务器跨，并将traceid保存到一个状态存储中。稍后，在transform管道中，我访问statestore并从transform()方法中捕获跟踪。这是处理流处理中的跟踪的好方法吗？
input
.mapValues(toSomethingThatMyAppUnderstands)
.mapValues(this::startStreamTrace)
.filter((k, v)
浏览 0提问于2018-10-18得票数 3
回答已采纳
1回答
当我在勇敢的浏览器中测试我的侧时，我在Bootsratp 4中开发了一个网站。有些功能不起作用。但在其他浏览器中也是如此。如何避免这种情况？当我检查的时候我得到了这个
.sideads {
display: none !important;
}
浏览 1提问于2021-08-05得票数 0
1回答
模板类链接-时间错误
、、、、
可能重复：
嗨,
我有一个c++项目，它由几个头文件和源文件组成。为了用模板修改类，我发现所有方法定义都必须包含在头文件本身中，否则会导致链接时错误。这是什么原因，我怎样才能克服这一切？
谢谢！！
浏览 1提问于2010-05-18得票数 1
我使用的是Spring cloud stream绑定器kafka，Edgware.SR4版本。
我已经为消息有效负载设置了自定义标头，并发布了它，但我在消费者端看不到这些标头。
我已经使用消息对象来绑定有效负载和头部。我尝试添加属性spring.cloud.stream.kafka.binder.headers，但不起作用
制片人：
Application.yml
spring:
cloud:
stream:
bindings:
sampleEvent:
destination: sample-event
cont
浏览 130提问于2019-05-24得票数 0
当使用Brave默认指纹块时，Chartjs中的图表不再正确呈现。
您可以尝试使用勇敢的浏览器：访问此页面。
然后尝试禁用指纹块，单击地址栏内的勇敢图标，然后选择:允许指纹。
到底怎么回事？我能做些什么来缓解这个问题呢？
示例：
浏览 4提问于2022-09-26得票数 0
我注意到，自从Kafka 0.8.2.0以来，Kafka附带了一个新的maven模块：
<!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-clients</artifactId>
<version>0.8.2.0</version>
</
浏览 0提问于2018-07-21得票数 2
回答已采纳
1回答
我使用以下代码使用gitpython：
g = git.cmd.Git(r'C:\Users\alex\Files\Repo\Scripts')
g.reset('--hard')
g.pull()
但我得到了以下错误：
GitCommandError: Cmd('git') failed due to: exit code(1)
cmdline: git pull
stdout: 'Updating c169660..ebe18ef'
stderr: 'error: Your local changes to
浏览 15提问于2022-09-16得票数 1
我已经使用npx hardhat node启动了一个默认配置的安全帽网络。运行此命令后，我将看到Started HTTP and WebSocket JSON-RPC server at http://127.0.0.1:8545/和20个种子帐户的列表以及它们的私钥。
然后，在Metamask中，我进入了“自定义RPC”网络配置，并输入了以下内容：
网络名称:草帽
新RPC：http://localhost:8545
链号: 31337
但是，当我尝试应用这些更改时，我会看到以下错误：Could not fetch chain ID. Is your RPC URL correct?
如果我
浏览 0提问于2021-03-05得票数 6
回答已采纳
我正在尝试使用kafka-avro-console-producer发布一个具有键(带模式)和值(带模式)的消息。kafka环境(用于kafka、connect、zookeeper和模式注册表的Confluent6.2.0版本)都正常启动，我可以确认我的连接器已经安装好了。问题是，当我发送消息时，我的接收器连接器失败，并出现无法诊断的错误。 如有任何帮助，我们将非常感谢： 我生成一条AVRO消息，如下所示： docker exec -it schema-registry \
/usr/bin/kafka-avro-console-producer \
--broker-list ht
浏览 78提问于2021-10-04得票数 0
回答已采纳
我有一个问题，使用RetryableTopic连同开放的弹跳力引导功能。RetryableTopic定义如下所示：
@RetryableTopic(
attempts = "3",
backoff = @Backoff(delay = 3000, multiplier = 2.0),
topicSuffixingStrategy = TopicSuffixingStrategy.SUFFIX_WITH_DELAY_VALUE,
kafkaTemplate = "dltKafkaTemplate",
浏览 14提问于2022-09-29得票数 0
回答已采纳
我试图用GlobaKTable加入流，得到了序列化问题。将KStream<String,String>的productStream与productTable连接是GlobalKTable<String,Product> (这里的产品是AVRO消息)下面的一段代码正在进行连接， KStream<String, Product> detailedProductStream = productStream.join(
productTable,
(productStreamKey, productS
浏览 29提问于2020-05-03得票数 0
我对springboot kafka是个新手，我在这篇文章之后创建了一个例子。
我当前使用的是spring.kafka.version 1.1.6
我想向消息添加自定义标头，这样我就可以在标头中发送某些属性，例如: fileName、fileId
我发现你可以将kafka元数据设置为头部，但这并不能满足我的目的。
我有什么办法可以做到这一点吗？如果可能的话，如果你能分享一个例子，我将非常感谢。
浏览 12提问于2018-02-23得票数 0
我在应用程序启动过程中启动Simperium。在将对象保存在用于启动simperium实例的上下文之外的上下文中之前，一切工作正常。如果这些“桶没有装入……”错误被忽略，或者我应该以不同的方式管理后台线程的simperium实例和NSManagedObjectContexts？谢谢!
浏览 0提问于2013-06-01得票数 0
回答已采纳
我正在尝试创建一个简单的Kafka客户端，它是从Springboot应用程序运行的。我的要求是使用Kafka 0.8.2.2版本。应用程序在一开始运行良好，然后我得到了这个异常，我无法找到根本原因。
在Kafka日志中，我看到以下异常：
来自分区TESTQA上的客户端测试组的相关id为0的偏移请求失败，原因是分区TESTQA上的引线不是本地的，broker 256上的2 2017-07-21 03:40:54,186信息kafka.network.Processor:正在关闭到/的套接字连接。
kafka.common.NotLeaderForPartitionException: null
浏览 8提问于2017-07-21得票数 5
我正在使用kafka包附带的zookeeper的kafka。我还使用了spring cloud stream和kafka活页夹。
我想看看如果zookeeper关闭会发生什么，而kafka代理正在运行。我通过spring cloud stream源给kafka主题发了一些东西。令我惊讶的是，spring cloud stream并没有得到异常，而是说它没问题。然而，我的物品不在kafka队列中。这是预期的行为，还是bug？如果zookeeper关闭了，有什么我可以配置的东西来得到一个异常返回吗？
浏览 0提问于2017-08-11得票数 1
1回答
Detail:，我正在尝试使用docker-compose.yml文件运行和映像，该文件附在本文的底部。
为了测试容器，我遵循了。它指的是一些在映像中不可用的脚本，如bin/kafka-server-start.sh。我还尝试使用docker exec -it zookeeper bash和docker exec -it kafka bash遍历容器，并在/bin/目录中找到zkServer.sh和其他一些脚本。
问题：问题--问题是我不知道如何使用它，因为config/server.properties在容器中可用，而不是动物园管理员。所以我不知道正确的解决办法。下载脚本并将它们放到主机目录
浏览 1提问于2019-07-03得票数 1
回答已采纳
我正在使用Debezium SQL Server Source connector通过CDC将数据推送到Kafka。SQL Server表中的数据是连续插入的。当Kafka宕机时，数据还会插入到该表中吗？如果是这样，当我的Kafka打开时，如何获得这些记录？
浏览 13提问于2020-05-22得票数 0
回答已采纳
我有一个以下代码： NSString *str = nil;
currentUtterance = [[AVSpeechUtterance alloc] initWithString: str];
[_speechSynthesizer speakUtterance:currentUtterance]; 我想问为什么这段代码没有抛出任何异常？取而代之的是，didFinishSpeechUtterance代表在演讲结束后调用。
浏览 25提问于2019-02-21得票数 0
我试图在我的spring侦听器中访问各种KafkaHeaders属性：
下面是我获取KafkaListenerContainerFactory的代码：
public KafkaListenerContainerFactory<ConcurrentMessageListener<String,GenericRecord>> kafkaListenerContainerFactory(final KafkaProperties kafkaProperties){
final ConcurrentKafkaListenerContainerFactory<String
浏览 1提问于2021-10-17得票数 0
我设置了一个Flink工作，向Kafka主题写一些消息。它使用FlinkKafakProducer作为接收器。我验证了输出Kafka主题中写入了消息，但Flink指标numRecordsOut始终显示0。同样，在Flink Web UI中，发送的字节也始终显示0B。
记录输出数量不能反映实际数量的原因是什么？
浏览 20提问于2019-03-28得票数 1
回答已采纳
我有spring引导应用程序，它有下一个依赖项：
dependencies {
implementation 'org.springframework.boot:spring-boot-starter-web'
implementation 'org.springframework.cloud:spring-cloud-starter-sleuth'
developmentOnly 'org.springframework.boot:spring-boot-devtools'
implementation "com.datadoghq:d
浏览 2提问于2021-06-04得票数 2
回答已采纳
1回答
我使用一个简单的spring引导应用程序来使用卡夫卡主题，并将容器工厂配置为SeekToCurrentErrorHandler
@Bean
public ConcurrentKafkaListenerContainerFactory<Object, Object> kafkaListenerContainerFactory(ConcurrentKafkaListenerContainerFactoryConfigurer configurer,
浏览 0提问于2021-11-19得票数 2
我了解到Kafka connect可以在集群模式下部署。并且工作人员在数据源和kafka主题之间移动数据。我想知道的是，如果工作人员在数据源之间移动数据到kafka主题时失败，会不会有数据丢失？如果发生数据丢失，我们如何从连接器获取数据，或者kafka connect会自动处理它吗？
浏览 33提问于2021-01-22得票数 0
回答已采纳
1回答
卡夫卡流连接表太大
、、、
我想使用在KStream上执行一个左联接，并使用一个KTable将表的一些字段添加到流中。
对于包含所有相关条目的表的更小版本(大约1,300项)，一切都很好。
一旦我使用了整个表(大约200,000个条目)，就会在行中得到一个NullPointerException，其中包含KTable的Avro (GenericRecord)的相关字段。
当我在KSQL中执行相同的左联接操作时，表中添加的字段为NULL。表中存在相关的连接键，但是在KSQL中查询它们需要大约。20秒后他们才会出现。
表是否可能太大，无法执行左联接？如果是这样的话，我能做些什么让联接使用整个表吗？
出于开发目的，我目前使用的
浏览 0提问于2019-08-08得票数 0
我是阿帕奇卡夫卡的新手。我有一个服务器10.33.41.20，其中我在/tmp/LsCrak.log中接收日志文件，它每秒钟更新一次。我已经在另一个vm server2 10.33.41.22中安装了Kafka 2.4.0。我应该使用卡夫卡控制台生产者如下所示。但是，如何才能获得远程文件，使我不会丢失任何数据？
kafka-console-producer.sh --broker-list kftest1:9092,kftest2:9092,kftest3:9092 --topic kafka-LsCrak-topic &
浏览 4提问于2022-04-11得票数 0
回答已采纳
我正在尝试创建一个新应用的内部测试版本，在Releases页面上，它说有一个错误。当我扩展这个错误时，它说：
“错误。您必须让我们知道您的应用是新冠肺炎联系人跟踪程序还是状态应用程序。”
没有说明如何说我的应用程序不是关于COVID的，我在Play Developer UI中找不到任何地方可以说应用程序是否是COVID应用程序。
我的应用程序属于音乐类，所以它不像医学或任何东西。
知道如何删除这个错误吗？我已经到处打猎好几个小时了！
浏览 3提问于2021-08-17得票数 11
当我试图从队列中读取时，使用者抛出了这些错误，我认为这是因为我没有正确地配置反序列化器，因为我知道在使用者和生产者中应该是相同的，所以我为两者创建了相同的avro，有一段时间它已经停止工作，我不太清楚为什么。先谢谢你。
Exception in thread "Promotions_Handler-a2f86d00-554e-43c5-b984-faafb7524faf-StreamThread-1" org.apache.kafka.streams.errors.StreamsException: Deserialization exception handler is se
浏览 15提问于2022-10-22得票数 0
回答已采纳
我是卡夫卡的新手，我想问一个问题。 如果有3个Kafka brokers( kafka1，kafka2，kafka3)(它们在同一个Kafka集群中)和topic=test(replication=2)，kafka1有领导者分区，kafka2有追随者分区。 如果producer将数据发送到kafka3，那么数据如何存储在kafka1和Kafka2中？ 我听说，如果producer向kafka3发送数据，那么zookeeper会找到拥有引导者分区的代理，并返回代理的域名或IP地址。然后，生产者会将元数据重新发送给broker。 是对的吗？或者如果是错的，请告诉我它是如何工作的。 非常感谢!
浏览 12提问于2020-06-27得票数 0
我正在学习如何将kafka与apache camel集成，我遇到了以下错误。我在C:/收件箱文件夹中创建了一个文件，并希望使用kafka使用者使用其中的文本。我使用的是camel.Below 3.1.0版本的代码
package com.javainuse;
import org.apache.camel.builder.RouteBuilder;
public class SimpleRouteBuilder extends RouteBuilder {
@Override
public void configure() throws Exception {
String t
浏览 5提问于2020-07-01得票数 0
我很难从Datadog中kafka.consume的java服务跟踪来解释这个输出。我希望父级(kafka.consume)跨越子代的整个期间：
您可以看到kafka.consume被跟踪为14.9秒的持续时间，但是子程序的跨度超过了这一点。怎么一回事？
浏览 5提问于2022-11-08得票数 0
1回答
我使用的是log4j，所以有不同的日志格式。我能够使用下面的多行格式将大多数日志从fluentd发送到splunk，但很少有日志的行为不同(日志具有不同的日期格式)。
<source>
@type tail
path /tmp/LOG_SPLUNK.*
pos_file /tmp/my-splunk.pos
path_key log_type
read_from_head true
tag "splunk.#log.mylogs"
format multiline
format_firstline /^\[/
format1 /\
浏览 5提问于2022-04-13得票数 0
回答已采纳
2回答
我正在我现有的CDH5.5.2集群上安装Kafka-2.0，下面是我遵循的步骤
从CM添加服务
选定的Kafka (在此之前，我下载并在所有节点上分发和激活kafka包)
为KafkaBroker选择1个节点，为Kafka MirrorMaker选择4个节点
然后，我用镜像制造者节点之一更新了我的目标代理列表(bootstrap.servers)属性，用同一个节点更新了Source列表(source.bootstrap.servers)
下面是我得到的错误(日志文件)
KafkaServerStartable启动期间发生致命错误。准备关闭java.nio.HeapByteB
浏览 3提问于2016-04-04得票数 0
1回答
在运行在多个实例中的基于Kafka的分布式JVM应用程序中，我需要对特定Kafka主题中的特定消息在特定可配置时间内(此超时值由业务逻辑驱动，可能会发生变化)的事件采取操作。
我如何才能以集群安全的方式实现这一点？
浏览 0提问于2020-09-29得票数 2
我正在尝试从log4j2到Kafka的主题的流日志。我的zookeeper和kafka服务器正在运行，我已经为此创建了一个主题。
Unable to write to Kafka in appender [Kafka] java.util.concurrent.TimeoutException: Timeout after waiting for 30000 ms.
at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:76)
at o
浏览 2提问于2018-07-03得票数 0
我通过kafka服务在Centos7实例上运行于Content-3.3.0平台上，发布了一些自定义Java类型的“InventoryEvent”事件，使用以下两个步骤：
命令将JSON事件发布到kafka-rest中。
curl -X POST -H "Content-Type:application/vnd.kafka.json.v2+json" --data '{"records" : [{"value" : {"id":1231, "eventType": "inventory.tra
浏览 3提问于2017-12-19得票数 2
回答已采纳
我有一个Kafka实例和一个简单的spring引导应用程序，其中包含一个REST控制器和一个ProducerListener bean。控制器接受一条简单的String消息并通过KafkaTemplate将其发送给Kafka。我希望ProducerListener记录一条info消息，但是缺少跟踪id和span id。在我看来，它应该包括在日志中。 我使用Spring Cloud Sleuth和Spring Kafka starters。 消息本身通过Kafka主题成功地发送到另一个spring启动应用程序，该应用程序正确地获取了跟踪id，所以我假设问题只与ProducerListener有
浏览 27提问于2019-10-04得票数 1
1回答
卡夫卡分区和偏移消失了
、、、
我的Kafka客户端正在GCP环境中运行，启用了自动缩放功能(GCP将实例计数保持在至少两个，并且由于CPU使用率低，它大多是2个)。在这两个VM中运行的使用者组几个月来一直在使用来自20个分区中的各种主题的消息，最近我注意到旧主题中的分区缩小到只有1 (!)该消费者组的偏移量被重置为0。主题分区目录也从kafka-log目录中删除。奇怪的是，最近创建的主题分区是完整的。我有3个不同的环境(都在GCP中)，这发生在所有三个环境中。我们没有看到任何丢失的消息或数据问题，但我们想了解发生了什么，以避免再次发生这种情况。
kafka代理和动物园管理员在同一个GCP计算引擎实例中运行(我知道这不是最佳
浏览 2提问于2017-12-15得票数 1
1回答
在我的应用程序中，我获得使用kafka排队并保存在磁盘上的数据，以及从kafka获取这些数据并进行处理的使用者。但当我的消费者试图阅读卡夫卡的数据时，我得到的例外是：
2017-06-09 10:57:24,733 ERROR NetworkClient Uncaught error in request completion:
org.apache.kafka.common.KafkaException: Error deserializing key/value for partition TcpMessage-1 at offset 155884487
at org.apache.kaf
浏览 2提问于2017-06-09得票数 1
回答已采纳
我们在使用MapR Spark streaming (1.6.1)连接Apache kafka集群时遇到问题。设置详情如下：
·带Spark 1.6.1的MapR集群(3节点集群)
·Apache Kafka集群v0.8.1.1 (5节点集群)
我们使用的是mapr v1.6.1-ampr-1605中的‘spark-streaming kafka’库。我们还尝试使用apache spark (而不是mapr spark)在本地模式下运行，效果非常好。
下面是错误的堆栈跟踪：
Exception in thread "main" org.apache.kafka.common.c
浏览 5提问于2016-08-17得票数 0
有没有可能追踪卡夫卡的消费者？也许是某种方式让一个消费者把自己登记为一个卡夫卡主题的消费者？
如果#1是可能的，那么卡夫卡是否也有可能跟踪消费者消费信息的时间？
在应用程序本身中实现这些特性是可能的，但我想知道Kafka是否已经提供了这样做的方法。我找不到关于这些特性的任何文档，所以也许在Kafka中这是不可能的，但是得到确认是很好的。谢谢!
浏览 0提问于2018-08-09得票数 0
1回答
我对kafka API有以下问题。我用以下命令设置我的客户：
<code>A0</code>
然后
<code>A1</code>
我想从Kafka中读取数据，从这些数据中更新数据库。但如果更新失败，我想重试，直到它工作。所以我想将DB事务应用到kafka，i.a。如果我的数据库事务是OK的，那么移动kafka指针，但如果它失败了，那么从相同的位置重试。
在我的代码中，
<code>A2</code>
没有像预期的那样工作，这意味着“如果kafka崩溃，那么从提交的位置重新启动”。但是，当我的DB事务失败时，即使我不使用c
浏览 31提问于2018-12-21得票数 1
回答已采纳
当试图启动一个具有Kafka绑定器活动的项目时，控制台中会提示以下内容：
org.springframework.context.ApplicationContextException: Failed to start bean 'inputBindingLifecycle';
Caused by: java.lang.NoSuchMethodError: java.util.List.of(Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljava/lang/Object;Ljav
浏览 8提问于2022-05-26得票数 0
回答已采纳
我试图为我的Kafka集群(即生产者->主题->消费者)绘制一个总体拓扑结构。
对于主题到使用者的映射，我可以使用kafka-consumer-groups.sh脚本获得它。
然而，对于从制片人到主题的映射，我理解在香草卡夫卡中没有类似的脚本。
问题
架构注册表是否允许我们将元数据与生产者和/或主题相关联，或者以其他方式创建所有生产者到特定主题的映射？
浏览 5提问于2021-02-01得票数 0
1回答
我看到了一些我无法解释的行为。考虑一下test.cpp：
#include <iostream>
long double operator"" _N(long double a) { return a; }
int main(int argc, char** argv) {
long double t = 4.0_N;
}
发证
g++ -std=c++11 test.cpp
给我
test.cpp:2:22: error: expected suffix identifier
long double operator"" _N(long
浏览 3提问于2014-04-29得票数 3
回答已采纳
我正在使用Kafka Connect加快速度。尝试使用Kafka Connect Elasticsearch Service接收器连接器将我们的数据从Kafka移动到Elasticsearch。我有一个处理流，看起来像这样： 来自S3的文件记录->来自发布到->kafka主题的源应用程序的自定义处理->Kafka连接->弹性搜索 这适用于创建/更新的场景。但是，我们希望处理文件的删除场景。我们的应用程序发布一个删除操作的事件，并将其设置为Kafka消息中标头值的一部分。我们希望删除文档本身，而不是使用此删除操作信息更新elastic中的文档。 我们如何使用Kafka
浏览 23提问于2021-04-07得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
