如何将 RPC 请求发送到同一 Kubernetes 服务上同一 Kafka Streams 应用程序实例的另一个实例。
注意:以前在 Docker 上使用 application.server
公开当前实例 ip:port 时,此方法有效。属性(property)
例如ReplicaSet=2
StreamApp 实例 1 端点 = 1.2.3.4:7079
StreamApp 实例 2 端点 = 1.2.3.5:7079
我想从实例 1 发送一个休息请求,访问实例 2 上的远程交互式查询
我已经尝试过的
我从实例 1 -> 实例 2 发送了一个 CURL 请求:但收到 404 错误
curl -X GET "http://1.2.3.5:7079/user/1" -H "accept: application/json"
但如果我从 K8 Host -> Instance 2 发送 CURL 请求:我得到一个 200 好的
curl -X GET "http://1.2.3.5:7079/user/1" -H "accept: application/json"
#values.yml
replicaCount: 1
image:
repository: "docker.hosted/steam-app"
tag: "0.1.0"
pullPolicy: Always
pullSecret: "a_secret"
service:
name: http
type: NodePort
externalPort: 7079
internalPort: 7079
kafka:
host: "kafka.default"
port: "9092"
ingress:
enabled: false
部署.yml
apiVersion: extensions/v1beta1
kind: Deployment
metadata:
name: {{ template "stream-app.fullname" . }}
labels:
app: {{ template "stream-app.name" . }}
chart: {{ .Chart.Name }}-{{ .Chart.Version | replace "+" "_" }}
release: {{ .Release.Name }}
heritage: {{ .Release.Service }}
spec:
replicas: {{ .Values.replicaCount }}
template:
metadata:
labels:
app: {{ template "stream-app.name" . }}
release: {{ .Release.Name }}
spec:
containers:
- name: {{ .Chart.Name }}
image: "{{ .Values.image.repository }}:{{ .Values.image.tag }}"
imagePullPolicy: {{ .Values.image.pullPolicy }}
env:
- name: KAFKA_HOST
value: "{{ tpl .Values.kafka.host . }}"
- name: KAFKA_PORT
value: "{{ .Values.kafka.port }}"
- name: MY_POD_IP
valueFrom:
fieldRef:
fieldPath: status.podIP
- name: MY_POD_PORT
value: "{{ .Values.service.internalPort }}"
ports:
- containerPort: {{ .Values.service.internalPort }}
livenessProbe:
httpGet:
path: /actuator/alive
port: {{ .Values.service.internalPort }}
initialDelaySeconds: 60
periodSeconds: 10
timeoutSeconds: 1
successThreshold: 1
failureThreshold: 3
readinessProbe:
httpGet:
path: /actuator/ready
port: {{ .Values.service.internalPort }}
initialDelaySeconds: 60
periodSeconds: 10
timeoutSeconds: 1
successThreshold: 1
failureThreshold: 3
resources:
{{ toYaml .Values.resources | indent 12 }}
{{- if .Values.nodeSelector }}
nodeSelector:
{{ toYaml .Values.nodeSelector | indent 8 }}
{{- end }}
imagePullSecrets:
- name: {{ .Values.image.pullSecret }
服务.yml
kind: Service
metadata:
name: {{ template "stream-app.fullname" . }}
labels:
app: {{ template "stream-app.name" . }}
chart: {{ .Chart.Name }}-{{ .Chart.Version | replace "+" "_" }}
release: {{ .Release.Name }}
heritage: {{ .Release.Service }}
spec:
type: {{ .Values.service.type }}
ports:
- port: {{ .Values.service.externalPort }}
targetPort: {{ .Values.service.internalPort }}
protocol: TCP
name: {{ .Values.service.name }}
selector:
app: {{ template "stream-app.name" . }}
release: {{ .Release.Name }}
最佳答案
关于kubernetes - 当 ReplicaSet=2 时发现+请求 Kubernetes 上的 Kafka Streams 实例,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/54346482/