Sleuth 3.0.3 无法在 kafka 日志中与 Kafka 配合使用
我是侦探新手。 我添加了侦探依赖项，如下所示。 org.springframework.cloud spring-cloud-starter-sleuth 并对正常日志的日志模式进行了相应的更改，…
从本地机器访问在 minikube 中运行的 bitnami/kafka
我正在尝试访问使用 helm 部署的 bitnami/kafka 集群。我需要能够从本地计算机向 kafka 发送消息，然后让我的 Pod 处理数据。 我使用以下命令来启动集…
Trigger.Once Spark 结构化流媒体与 KAFKA 可能吗？
使用 Trigger.Once 的 Spark 结构化流是否允许直接连接到 KAFKA 并使用 MERGE 语句？或者该数据必须来自增量表吗？ 这个 https://docs.databricks.com…
在 fastapi 应用程序中使用来自 kafka 主题的消息并将其发送给特定客户端
我拥有的。 一个FastAPI应用程序，由两个子应用程序组成，并安装了特定路径。其中之一是 websocket 应用程序。 具有两个主题的单节点 Kafka 集群。一…
Kafka 主题 Avro 键未从 Cassandra 源连接器填充
我有一个 Kafka 主题，它具有以下 Avro Key Schema： { "type": "record", "name": "onboardingStatusKey", "namespace": "onboarding", "fields": [ …
如何在部署期间实现 Kafka Streams 应用程序的高可用性？
主要问题：我们在 Kubernetes 上运行 Kafka Streams (Java) 应用程序，以在 Kafka 集群（运行 Confluence Community Edition v7.0/Kafka v3.0）中消费…
如何使用 ksql 将 String 类型转换为结构数组
我在 Kafka 中有一个主题，其架构如下： Name Type ID STRING ORDER_STATUS INTEGER ORDER_ITEM_JSON STRING ORDER_ITEM_JSON 本身是一个项目字符串：…
奇怪的 Kafka 消费者组重新平衡
我的 kafka 主题有两个分区和单个 kafka 消费者。我已经在 AWS 中部署了我的消费者应用程序（spring kafka）。在日志中我看到卡夫卡消费者不时地重新…
从缓存中重新填充 _schemas 主题
几天前，我们丢失了 kafka 代理上的所有数据，以及架构注册表使用的内部 _schemas 主题中的所有消息。 不过，模式注册表节点仍然启动并运行，因此我们…
spring kafka消费者中的无限重试@retryabletopic
我正在使用 @RetryableTopic 在 kafka 消费者中实现重试逻辑。 我给出的配置如下： @RetryableTopic( attempts = "4", backoff = @Backoff(delay = 30…
