请问如何查看某个埋点的不同参数值啊，比如埋点Duration，实际参数包含H=角色所在服务器(若服务器与区的概念重合，则为0)U=游戏中角色id(在人物界面或设定中可直接确认到的roleid)T=游戏前台时长
如何在后台查看这个埋点对应的参数值呢，谢谢啦
浏览 339提问于2023-03-02
指定代理名称和端口似乎不能做到这一点。我没有指定我的kafka集群在哪里： .apply(KafkaIO..withTopic("pageviews") Exception in thread "main" org.apache.beam.sdk.Pipeline$PipelineExecutionException: org.apache.kafka.common.KafkaExceptio
浏览 4提问于2020-06-21得票数 1
我用python编写了一个消费者来从kafka获取数据。/kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --list
我的python进程仍在运行。我尝试tcpdump，发现应用程序仍在尝试连接kafka。但是没有数据响应。有人能帮帮我吗？
浏览 26提问于2018-08-01得票数 1
04, 2017 9:46:30 AM org.apache.beam.sdk.io.kafka.KafkaIO$UnboundedKafkaReader advanceApr 04, 2017 9:46:30 AM org.apache.beam.sdk.io.kafka.KafkaIO$UnboundedKafkaReader:64)
at org.apache.beam.sdk.coders.BigEndianLon
浏览 1提问于2017-04-04得票数 3
5回答
主要目标是聚合两个Kafka主题，一个是压缩的慢速移动数据，另一个是每秒接收的快速移动数据。有没有任何人可以给我指点的文档/例子，这样我就可以了解你将如何使用Kafka AVRO和Beam。任何帮助都将不胜感激。我更新了我的代码：import org.apache.beam.sdk.Pipeline;
import org.apache.beam.sdk.coders.Av
浏览 7提问于2019-02-19得票数 2
下面有使用连接到kafka的代码。)) as pipeline: consumer_config={
"bootstrap.servers*,beam_java_sdk:latest' --其中beam_java_sdk:latest是一个基于apache/beam_java11_sdk:2.27.0的码头映像，这将在其entrypoint.sh这很快就不可避免
浏览 9提问于2021-02-01得票数 1
我想开发一个python脚本来创建主题在MSK使用AWS SDK boto3。我没有看到任何在Kafka.client中创建主题的方法。我可以使用kafka-python，但我想使用AWS SDK或CDK
请提个建议。
浏览 3提问于2020-07-24得票数 1
我已经查看过ConsumerRecord，但是由于这是一个监视服务，我不认为我应该使用.poll()，因为如果我的监视服务是直接来自Kafka的，我可能会导致一些记录丢失。我知道有CLI kafka-console-consumer可以根据分区和偏移量获取消息的时间戳，但不确定这是否是一个可用的SDK。
有谁有任何我可以通过的洞察力或阅读资料来获得时间间隔吗？我一直试图找到一个SDK或任何类型的API可以做到这一点。
浏览 12提问于2022-07-15得票数 1
我正在努力建立一个数据摄取管道使用Apache光束"go“SDK。我的流程是使用Kafka队列中的数据，并将数据持久化到Google Cloud Bigtable (和/或另一个Kafka主题)。到目前为止，我还没有找到用"go“编写的Kafka IO连接器(也称为Apache I/O转换)(但是我能够找到java版本)。<String, String>read()
浏览 9提问于2020-01-25得票数 1
从服务器上，我能够连接并从配置了SSL的远程kafka服务器主题中获取数据。Exception in thread "main" org.apache.beam.sdk.Pipeline$PipelineExecutionException: org.apache.kafka.common.KafkaExceptionorg.apache.kafka.common.utils.AppInfoParser$AppInfo <init>
INFO: Kafka version
浏览 13提问于2019-01-24得票数 1
回答已采纳
1回答
;import org.apache.beam.sdk.io.kafka.KafkaIO;import org.apache.beam.sdk.transforms.DoFn;impor
浏览 23提问于2020-08-25得票数 0
1回答
我无法通过代码连接到本地运行的Kafka实例-我可以使用Kafka-Console-Producer和Kafka-Console-Consumer成功连接，但当我使用Kafka Java SDK并简单地使用[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer[kafka-producer-network-t
浏览 468提问于2020-05-25得票数 2
回答已采纳
我正在尝试使用python code.My代码中的kafka.ReadFromKafka()方法读取kafka主题中的数据，如下所示：import apache_beam as beam
plants = ( | 'read' >
浏览 1提问于2020-07-07得票数 0
我已经更新了我的统一项目dll，之后我得到了这个错误。 .SetValueDeserializer(new AvroDeserializer<GenericRecord>(schemaRegistry).AsSyncOverAsync())
浏览 2提问于2020-04-12得票数 1
回答已采纳
1回答
卡夫卡滑动窗
、、、
我希望实现Kafka流滑动窗口，并为特定的窗口持续时间执行聚合，并且每个窗口只输出一个结果。
现在，我已经搜索了整个堆栈溢出，但是我无法找到与滑动窗口相关的代码实现。
浏览 0提问于2019-07-18得票数 0
1回答
我正在尝试从命令行aws中正确地向我的aws集群添加一个火花步骤。我有一个大的数据集(数千个.csv文件)，我需要阅读和分析。我有一个python脚本，看起来类似于：import pandas as pdfrom pyspark.sql.types import *import boto3
sc = SparkContext.getOrCreate(
浏览 2提问于2018-06-04得票数 0
1回答
假设有一个用户A，它通过适当的事务将一些以太转移到用户B。
简而言之，我想知道两个事务会发生什么变化，以及区块链将如何丢弃其中一个而保留另一个事务？
浏览 0提问于2020-09-18得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号