Istio Kafka Wire协议支持
Istio是一个开源的服务网格平台，用于管理和连接微服务应用程序。它提供了流量管理、安全性、可观察性和策略执行等功能。Istio通过在应用程序之间注入一个专用的代理（称为Envoy）来实现这些功能。
Kafka是一个分布式流处理平台，用于处理和存储实时数据流。它具有高吞吐量、可扩展性和容错性的特点，适用于构建实时数据流应用程序。
Wire协议是一种轻量级的二进制协议，用于在应用程序之间进行高效的通信。它具有较小的数据包大小和较低的序列化/反序列化开销，适用于网络通信和数据传输。
Istio Kafka Wire协议支持指的是Istio对Kafka使用Wire协议进行通信的支持。通过使用Wire协议，Istio可以更高效地与Kafka进行交互，提高数据传输的性能和效率。
在实际应用中，Istio Kafka Wire协议支持可以用于以下场景：
- 微服务架构中的消息传递：通过使用Istio和Kafka结合使用，可以实现微服务之间的异步通信和消息传递。Istio提供了流量管理和安全性功能，而Kafka提供了可靠的消息传递机制。
- 实时数据处理：通过将Istio和Kafka结合使用，可以构建实时数据处理应用程序。Istio提供了流量管理和可观察性功能，而Kafka提供了高吞吐量和可扩展性的数据存储和处理能力。
腾讯云提供了一系列与Istio和Kafka相关的产品和服务，可以帮助用户快速构建和部署基于Istio和Kafka的应用程序。以下是一些推荐的腾讯云产品和产品介绍链接地址：
- 腾讯云容器服务（Tencent Kubernetes Engine，TKE）：https://cloud.tencent.com/product/tke TKE是腾讯云提供的容器服务，支持使用Istio进行流量管理和安全性控制。
- 腾讯云消息队列 Kafka 版（Tencent Cloud Message Queue for Kafka）：https://cloud.tencent.com/product/ckafka 腾讯云提供的托管式Kafka服务，提供高可靠性、高吞吐量的消息传递能力。
请注意，以上只是一些推荐的腾讯云产品，其他云计算品牌商也提供类似的产品和服务。
相关·内容
我刚接触Istio，我们计划在K8S环境中使用Istio作为SSL Service Mesh，用于Kafka。 我想检查一下Istio是否支持Kafka Wire协议通信。 谢谢你的帮忙
浏览 22提问于2019-01-23得票数 1
回答已采纳
1回答
我可以通过Istio路由HTTP流量(例如，Elasticsearch和各种仪表板)，但我无法通过原始TCP流量。下面我有两个例子(postgres和红熊猫)。我在内部使用postgres和kafka客户端访问底层服务(mypostgres.default.svc.cluster.local和three-node-cluster-0.three-node-cluster.redpanda-system.svc.cluster.local)没有问题。
我的网关：
apiVersion: networking.istio.io/v1alpha3
kind: Gateway
metadata:
浏览 9提问于2022-01-28得票数 0
我有两个节点的Kafka集群。ip为1.1.1.1的node1和ip为2.2.2.2的node2所有流量都必须通过Egres控制器。如果应用程序中的客户端寻址ip为1.1.1.1的节点，则他应与该节点联系，而无需从Istio获得任何平衡
配置：
apiVersion: networking.istio.io/v1alpha3
kind: ServiceEntry
metadata:
name: kafka
spec:
hosts:
- kafka.host
addresses:
- 1.1.1.1/32
- 2.2.2.2/32
ports:
-
浏览 0提问于2020-07-31得票数 2
1回答
我已经将Kafka部署为状态集，并将zookeeper配置为leader selector，这是一个无头服务。Kafka运行得和预期的一样好。然而，我在配置Istio访问kafka时遇到了问题。 $ kubectl get pods -owide | grep -i kafka
kafka-mon-0 1/1 Running 0 3d1h <IP>
$ kubectl get svc -owide | grep -i kafka
kafka-mon-http LoadBalancer &l
浏览 16提问于2019-03-11得票数 2
1回答
我们在Kubernetes和使用Istio服务网格。目前，网关中的HTTPS存在SSL终端。我在istio代理日志中看到HTTP协议是HTTP1.1。
由于HTTP1.1的各种优点，我想将HTTP1.1升级到HTTP2。客户端应该通过SSL/TLS调用我们的服务HTTP2。
我正在使用这个作为这个主题的内部演示。
这些都是瓶颈：
( 1)我想提出一项计划，使改变最少。我知道我需要更新网关
apiVersion: networking.istio.io/v1alpha3
kind: Gateway
metadata:
name: bookinfo-gateway
spec:
select
浏览 1提问于2020-01-06得票数 1
回答已采纳
我有一个问题，那就是如何用Istio Ingress网关配置Strimzi操作符，以同时为引导和代理服务提供服务。
我已经将Istio部署到以下网关和虚拟服务中，用于服务器引导和代理：
apiVersion: networking.istio.io/v1beta1
kind: Gateway
metadata:
annotations:
name: strimzi-kafka-gw-broker
namespace: strimzi
spec:
selector:
istio: ingressgateway
servers:
- hosts:
- mys
浏览 8提问于2022-04-05得票数 0
回答已采纳
1回答
我正尝试在亚马逊网络服务的K8s 1.6集群中使用Istio。
我有一个Kafka pod/service运行旧的方式，有一个没有IP的" kafka-zk-broker-kafka.dev“服务，所以Kafka -zk-broker-kafka.dev服务(我在dev命名空间中)解析为我的3个Kafka pod的内部名称。这工作得很好。
~ # nslookup kafka-zk-broker-kafka.dev
Name: kafka-zk-broker-kafka.dev
Address 1: 10.33.0.11 kafka-zk-kafka-0.kafka-zk-
浏览 11提问于2017-07-27得票数 1
2回答
我正在尝试添加非常基本的rls1支持，通过允许用户提供外部stacks2作为环境变量来引导。我遇到了一个问题，客户端似乎拒绝了配置。
下面是我的Istio控制平面代码的一个独立的简化版本：
import (
"github.com/envoyproxy/go-control-plane/envoy/api/v2/core"
"istio.io/istio/pilot/pkg/model"
"istio.io/istio/pilot/pkg/networking/util"
ratelimit "github
浏览 2提问于2019-10-28得票数 1
3回答
使用案例，需要负载均衡UDP:69网络设备和运行在k8s上的应用程序之间的流量。Istio是否支持UDP流量负载均衡？
浏览 1提问于2018-08-22得票数 6
由于像Istio和Linkerd这样的服务网格专注于服务间的通信，而不是使用Kafka进行事件驱动消息传递，我是否可以扩展服务网格来实现事件驱动消息传递？
胡国兴(新加坡)
浏览 12提问于2020-06-03得票数 2
回答已采纳
1回答
我有Istiov1.6.4的k8s集群。默认情况下，侧插入是禁用的。我让卡夫卡集群在这个k8s上运行，安装了strimzi操作符。卡夫卡集群的工作没有任何问题时，卡夫卡以及客户端吊舱没有注入Istio代理。我的问题是:当我用kafka客户端和Istio代理注入创建一个吊舱时，我无法连接到Kafka集群。客户端的日志：
java.io.IOException: Connection reset by peer
在服务器端：org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 3692956
浏览 4提问于2020-07-09得票数 7
我希望按此正则表达式时间为特定行选择时间和值: Tue 22，6月22日，11:05:01，EDT 2021使用内存，用于K8s_POD_eventing cp-kafka示例30 k8s。
((?<time>(.*?)EDT 2021)((.|\n)*)(?<memoryblock>(?<=(eventing-kafka-cp-kafka)).*\%(\s)*(?<memory>.*)\s(?=\/).*(?=15\.51GiB)))
文本：
=======================
Tue 22 Jun 11:05:01 EDT 2021
浏览 3提问于2021-06-24得票数 1
回答已采纳
2回答
我使用istio入口网关和虚拟服务来公开不同的微服务。到目前为止，所有这些都是http服务，因此直接遵循istio的文档。
但在卡夫卡，我正面临一些问题。我使用头盔图表进行卡夫卡的安装。下面是用于它的values.yaml：
global:
storageClass: "kafka-sc"
replicaCount: 3
deleteTopicEnable: true
resources:
requests:
memory: 1024Mi
cpu: 500m
limits:
memory: 2048Mi
cpu: 1000m
z
浏览 3提问于2021-10-28得票数 2
如何在Istio中管理服务网格中的状态？ 我可以看到Kafka streams是一种选择。 如何在Istio/Kubernetes中管理状态？
浏览 14提问于2019-01-24得票数 1
回答已采纳
我正面临着下一个问题。我在问kubernetes我是否可以做一些操作：
$ kubectl auth can-i list secrets --namespace iotdevadm
no - no RBAC policy matched
在上面，我要求列出秘密。根据回应，我不能这样做。
但是：
$ kubectl get secrets
NAME TYPE DATA AGE
builder-dockercfg-9m9rf kubernetes.i
浏览 0提问于2020-05-26得票数 0
1回答
我有一个简单的有状态的SFTP功能，另一个服务尝试连接到它。
启用ISTIO后，sftp服务将关闭连接。我们可以找到这个日志：
Bad protocol version identification '\026\003\001'
路由正常。
服务：
apiVersion: v1
kind: Service
metadata:
name: foo
namespace: bar
spec:
ports:
- port: 22
targetPort: 22
protocol: TCP
name: tcp-sftp
selec
浏览 5提问于2021-09-10得票数 2
1回答
场景
Istio版本1.5.0在EKS 1.14之上。启用组件：
基座
飞行员
注意： Istio 1.5.0不赞成Mixer，移到遥测v2，这发生在特使代理侧车内。
我想使用Istio来支持一些现成的指标。
这是流程
我的计算机->网关->虚拟服务->虚拟服务B
我确保：
K8s服务对象有标签app
K8s部署对象及其pod模板有标签app
我可以很好地运行流程，这意味着配置是正确的。
问题在于遥测技术。
istio_requests_total{connection_security_policy="unknown",des
浏览 9提问于2020-03-28得票数 0
回答已采纳
如何使Istio路由自定义HTTP方法？
$ curl -v -X MYMETHOD https://myapp.com
< HTTP/2 400
< content-length: 11
< content-type: text/plain
< date: Wed, 29 Dec 2021 08:24:36 GMT
< server: envoy
< x-envoy-upstream-service-time: 1
<
* Connection #0 to host myapp.com left intact
Bad Request
apiVer
浏览 4提问于2021-12-29得票数 2
回答已采纳
当我在一个被坞化或kubernetes容器中运行Python微服务时，它工作得很好。但是有了Istio服务网格，它就不起作用了。
我为我的两个出站外部http添加了ServiceEntry。似乎我可以使用curl命令访问容器中的url内容表单，即服务网格中的url内容表单。因此，我认为服务条目很好，而且工作正常。
但是当我尝试使用Python中的xml.sax解析器的微服务时，它给了我upstream connect error or disconnect/reset before headers，尽管没有Istio，相同的应用程序工作得很好。
我认为这与Istio、特使或Python有关。
浏览 0提问于2018-12-22得票数 0
回答已采纳
我从Istiov1.5安装了一个现有的实例：
apiVersion: install.istio.io/v1alpha1
kind: IstioOperator
metadata:
namespace: istio-system
name: istio
spec:
profile: default
components:
ingressGateways:
- namespace: istio-system
name: istio-ingressgateway
enabled: true
k8s:
浏览 6提问于2020-06-19得票数 4
我按照说明使用istioctl upgrade将istio1.4.5安装升级到1.5.0。它工作正常，甚至通过了istioctl verify-install检查。
但是，当我启动Kiali时，它报告了Istio配置中的一些错误：
我检查了配置，看起来没有istio遥测服务：
浏览 6提问于2020-03-06得票数 0
回答已采纳
1回答
我正在尝试在istio入口网关中尝试ssl连接。
从这里，我假设istio入口网关在默认情况下应该终止ssl。
我已经通过istioctl安装了演示配置文件istio。我还安装了我的服务svc1。
除此之外，下面是我的资源与常规逻辑的关系：
apiVersion: networking.istio.io/v1alpha3
kind: Gateway
metadata:
name: vs-gateway
namespace: myns
spec:
selector:
istio: ingressgateway # use istio default controller
浏览 4提问于2020-01-02得票数 2
回答已采纳
我正在做一个副业，在业余时间学习Istio，其中的一部分就是接触Istio路由。 我正在尝试设置一个虚拟服务，这样"/“上的任何流量都会被路由到google.com。我可以让Virtual Services与集群内的任何pod/服务一起工作，但我似乎无法将Istio配置为路由到集群外的任何东西。 任何指导都将不胜感激，干杯
浏览 14提问于2019-02-13得票数 0
我在GKE集群中运行Istio Ingress。Service与NodePort一起运行。我想把它连接到谷歌的后端服务。但是，我们需要一个必须针对Istio运行的运行状况检查。您是否知道Istio是否公开任何HTTP端点来运行健康检查并验证其状态？
浏览 1提问于2018-08-15得票数 0
1回答
我正在尝试使用istio和特使为需要连接到外部mongodB服务器的服务实现服务网格，但由于某些原因，我的服务无法从istio代理到达外部mongodB服务器。
下面是我的服务的网关和虚拟服务配置
apiVersion: networking.istio.io/v1alpha3
kind: Gateway
metadata:
name: gtreviews
spec:
selector:
istio: ingressgateway
servers:
- port:
number:
浏览 0提问于2018-10-17得票数 0
1回答
我试图从EKS中的一个容器中连接到我的ElastiCache Redis Cluster5.0，该容器使用Istio作为侧车代理，但我经常被移动到错误循环。 我有1个分片和2个副本，并且我为每个分片+配置端点添加了一个ServiceEntry和一个VirtualService。 用于Istio路由的示例配置： kind: ServiceEntry
metadata:
name: redis-test-cluster
spec:
hosts:
- redis-cluster-test.XXXX.clustercfg.euw1.cache.amazonaws.com
ports:
浏览 17提问于2019-02-19得票数 2
直接的问题是:为什么Gradle没有解决我添加的这种依赖关系 dependencies {
//kafka-protobuf-serializer
implementation("io.confluent:kafka-protobuf-serializer:6.0.0")
} 根据mvn，这就是我如何在我的build.gradle中添加这样的依赖项 compile group: 'io.confluent', name: 'kafka-protobuf-serializer', version: '6.0.0'
浏览 155提问于2020-12-09得票数 5
回答已采纳
1回答
我们有一个问题，在upstream connect error or disconnect/reset before header中连接到Istio中的AWS是结果。我们的离题规则如下
apiVersion: config.istio.io/v1alpha2
kind: EgressRule
metadata:
namespace: <our-namespace>
name: rds-egress-rule-with
spec:
destination:
service: <RDS End point>
ports:
浏览 1提问于2018-05-14得票数 1
回答已采纳
ISTIO版本:1.9.4EKS集群版本: 1.14
我们已经在我们的项目中部署了ISTIO应用网格。我们使用istio的文档(即 )部署了外部授权。
使用的外部授权程序(如上面的文档所述)：
当我们从另一个API的荚中访问任何API时(即通过http)，使用curl命令，所有这些都可以正常工作。External服务获得调用，所有标头都传递给外部授权程序的v3检查方法。下面的信息被传递给源、主体、目标、标题:权限、方法、路径、接受、内容长度、用户代理、x-b3抽样、x-b3-spanid、x-b3-traceid、x-使节-尝试-计数、x-ext-authz、x转发-客户端-certx转发-p
浏览 3提问于2021-07-07得票数 0
我最近进入了Istio，并试图对网关的概念进行一番尝试。
因此，从根本上说，我明白它是什么:进入服务网格的入口。
然而，我不明白的是如何最好地使用网关。
我已经在我的k8s集群上安装了istio via helm，并浏览了bookinfo教程。
我创建了bookinfo-gateway
spec:
servers:
- hosts:
- '*'
port:
name: http
number: 80
protocol: HTTP
selector:
istio: ingressg
浏览 20提问于2019-07-19得票数 0
3回答
嗨，微服务专家，
我有一个关于微服务的服务到服务通信架构的问题。Istio或任何服务网格都可以使微服务通信的路由、发现和弹性易于管理。然而，它没有涵盖跨越多个微服务(一种分布式事务)的事务的重要方面，这在微服务的基于事件的体系结构中包含得很好。然而，显然，事件驱动架构没有很好地覆盖服务网格的各个方面。所以，我想知道，哪种方法更好，或者有一种方法可以将-service网格和事件驱动架构混合在一起，以利用这两种模式的优点。但如果这种混合是可能的，那么事件驱动总线(如Kafka)是否不会干扰Istio使用的侧车代理/控制平面的内部工作模式。
浏览 3提问于2019-04-05得票数 2
1回答
我们在Linux红帽子服务器上使用以下Kafka客户端
0.8.1 Release
Released March 12, 2014
Release Notes
Source download: kafka-0.8.1-src.tgz (asc, md5)
Binary downloads:
Scala 2.8.0 - kafka_2.8.0-0.8.1.tgz (asc, md5)
Scala 2.8.2 - kafka_2.8.2-0.8.1.tgz (asc, md5)
Scala 2.9.1 - kafka_2.9.1-0.8.1.tgz (asc, md5)
Scala 2.9.2 -
浏览 6提问于2020-01-07得票数 0
回答已采纳
我的istio入口网关中有以下代码 apiVersion: networking.istio.io/v1alpha3
kind: Gateway
metadata:
name: my-gateway
namespace: staging
spec:
selector:
istio: ingressgateway # use Istio default gateway implementation
servers:
- hosts:
- "my.mongodb.com"
port:
number: 27018
浏览 25提问于2019-02-13得票数 1
1回答
所以我有这样的设置：
AWS北草坪会议大楼(向前)
现在，我试图在Istio层实现速率限制。我跟踪了链接。但是，我仍然可以比我配置的API更多地请求API。更深入地研究一下，我在nginx中记录了X转发的头文件，它是空的。
那么，当我使用北草坪会议大楼时，如何在Istio中获得客户机IP呢？北草坪会议大楼转发客户端IP，但如何？头球？
编辑：
Istio版本: 1.2.5
ingressgateway配置为NodePort类型。
浏览 3提问于2019-11-14得票数 1
我试用了一个Oracle Cloud，并启动了一个新的Oracle Cloud Cluster。然后我在里面安装了Istio。但是Ingress设置不起作用。当我浏览到入口时，我一直收到来自Chrome的err_connection_reset消息。
此外，在Istio文档中，我尝试了不同的安装方法。
在Azure中，这很简单。但是在OKE，我想不通。
我尝试过Istio 1.6.2；1.6.0和1.5.5。我尝试通过门户启动OKE，然后尝试CLI。只是有点迷信了。
遵循不同的演练
但没那么走运。
浏览 1提问于2020-06-18得票数 0
1回答
目前，我正在使用云代理连接到Postgres数据库，作为一个侧服务器。然而，在使用Istio时，它引入了自己的侧翼，从而导致了吊舱中有两个代理程序。所以我想，加密的连接也可以用Istio建立吗？
基本上，。
。
编辑:可能是同样的问题：
所以我最后的结果是
apiVersion: networking.istio.io/v1beta1
kind: ServiceEntry
metadata:
name: external-db
spec:
hosts:
- external-db
ports:
- number: 5432
name: postgres
浏览 1提问于2020-11-24得票数 1
我在通过kafka库连接Event Hub时出现以下异常。 Caused by: org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'sasl_auth_bytes': Bytes size -1 cannot be negative
ERROR [pool-6-thread-1] STREAM - code="SAE-SP-A-1000: Stream processing failed, exiting ...",exception="Inv
浏览 57提问于2020-01-24得票数 4
我想使用ruby kafka客户端库来产生事件，但遇到了一个我不确定如何解决的问题。任何帮助都将不胜感激。
我试过使用kafka-rb (acrosa，mheffner和bpot forks)。问题是，无论我通过库向它发送什么，例如
require 'kafka'
host = 'localhost'
port = 9092
producer = Kafka::Producer.new(
:topic => 'login',
:host => host,
:port => por
浏览 2提问于2013-02-08得票数 3
回答已采纳
我正在使用带有GKE / GCP的Istio，并且所有工作都成功地使用Istio的经典HTTPS部署应用程序。 现在，我正在尝试为开发集群部署Kafka，并尝试将TCP流从Istio Gateway重定向到特定端口的kafka，但不起作用。 我已经检查了来自GCP的特定防火墙规则，但目前我认为阻塞点不在这里(一些数据包被GCP捕获，任何数据包都被阻止，所有端口都被打开)。 我已经在这个问题上工作了6个小时，所以如果有人已经有了这个问题，我将非常感激！ 我的Kubernetes版本是1.17.14-gke.400，Istio版本是1.4.10-gke.5。 您将在下面找到来自Istio的tcp
浏览 42提问于2020-12-10得票数 0
Kubernetes和Istio已经安装在集群中。三个微服务部署为吊舱。流量是
Micro service A to Micro Service B calls => HTTP
Micro service B to Micro service C calls => via Kafka
Micro service A expose a HTTP API to outside
我猜当客户端访问Ingres时，Istio在header中生成traceId和spanId并进入服务A。这些spanId和traceId是否在不使用之类的单独API的情况下传播到微服务B和C？
浏览 8提问于2020-02-27得票数 0
回答已采纳
我配置了来接受我的URL(使用https)，比如microservices.myexample.com，grafana.myexample.com等等。
一切正常，但是所有的urls都是公开的。
因为我被要求配置入口网关来保护microservices.myexample.com中的urls (Grafana有一个登录页面)。只有当请求在标头中包含一个令牌时，才允许访问。
但是当我应用这个yml文件时，所有的URL都被阻塞，并且它们需要头部，包括grafana.myexample.com
apiVersion: security.istio.io/v1beta1
kind: Authoriza
浏览 4提问于2020-02-06得票数 0
回答已采纳
如何配置Istio VirtualService将流量路由到侦听HTTPS的目标后端？
配置protocol: HTTPS或scheme: HTTPS无效。
apiVersion: networking.istio.io/v1alpha3
kind: VirtualService
metadata:
name: api-rpi-access
spec:
hosts:
- "test.example.com"
gateways:
- api-gateway
http:
- match:
- uri:
port: https
浏览 3提问于2020-05-20得票数 2
回答已采纳
1回答
我一直试图在Openshift集群之外访问我的Kafka代理，但它不允许我访问。我已经设置了所需的Openshift路径，并将其指向我的kafka服务。我试着在互联网上查看它，但是每次我都有一篇文章指向strimzi运营者/ AMQ运算符来实现这一功能。我现在在想，比特尼卡夫卡到底支持还是不支持路线？我找不到关于这件事的任何文件。有人能帮我指出正确的方向吗？
浏览 11提问于2022-11-18得票数 0
我试图把日志从卡夫卡顶部推到elasticsearch。
我在卡夫卡的留言：
{
"@timestamp": 1589549688.659166,
"log": "13:34:48.658 [pool-2-thread-1] DEBUG health check success",
"stream": "stdout",
"time": "2020-05-15T13:34:48.659166158Z",
"pod_name": "my-po
浏览 1提问于2020-05-15得票数 1
回答已采纳
1回答
在kiali中检测kafka事件
、、、、
我正在做一个使用istio和kubernetes的微服务架构，两个微服务使用kafka相互通信。我启用了kiali来可视化我的服务网格，但我的问题是我发现没有办法看到用kiali表示的kafka事件。
有人知道我是怎么做到的吗？(如果您需要更多信息，请告诉我)
浏览 5提问于2019-04-03得票数 0
1回答
为了上下文起见，我有这样的设置：
istio mesh external service
grpc | grpc 2 * istances
app:client -> envoy -> | aws classic load balance -> app:server
我得到了两个示例应用程序(客户机和服务器)，客户机通过grpc持久连接向服务器发送请求，服务器返回其私有ip。
我让它正常工作，但是客户端总是向同一
浏览 0提问于2018-05-20得票数 1
需要帮助建立授权政策。以Istio版本设置前提下的Kubernetes : 1.5.1
在没有授权政策的情况下，可以得到200英镑。503批准政策适用时的反应守则。
Ingressgateway访问日志(在没有授权策略的情况下工作)
2020-05-15T07:08:30.278Z "GET /v1/委托/测试HTTP/1.1“200 -”0 4 81 79“10.40.172.33 10.32.0.1 "Mozilla/5.0”(Windows 10.0；Win64；outbound|9091||REPLACED.REPLACED-NAMESPACENAME.svc.clu
浏览 3提问于2020-05-15得票数 0
我在努力实现
i am trying to access flow dyeing
，我期待着什么能从出来？
when i visit the testaaa with header, then route to testaaa-<header-branch>, and it will pass the header route to the testbbb-<header-branch>, use curl "http://gateway:gatewayport/" --header 'project-version: release-v1
浏览 3提问于2022-10-25得票数 0
回答已采纳
1回答
我使用Kafka头来传递用于日志记录的关联id，然后由Kafka拦截器使用它放入MDC。我的问题是头部信息到底存储在哪里，我的postgres DB没有任何用于存储消息头部信息的列，那么kafka将这些信息存储在哪里呢？它使用哪个数据存储区？下面是我的kafka_message表的列名。所有列都不存储标题信息。 ?
浏览 21提问于2021-09-02得票数 0
2回答
正如您可能知道的，Kafka在应用层使用二进制协议通过网络传输消息，这种未知协议在高度安全的网络中是有问题的。有什么消息代理工具可以替代Kafka的HTTP协议吗？
我们的任务是通过MAN网络将多个来源的数据发送到单个目的地。
首选基于开源和Java的解决方案。
提前谢谢你。
浏览 4提问于2017-09-27得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
云直播
对象存储活动推荐
腾讯云开发者
