-
Notifications
You must be signed in to change notification settings - Fork 64
/
deployment-tracing-opentelemetry.yaml
150 lines (150 loc) · 4.39 KB
/
deployment-tracing-opentelemetry.yaml
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaTopic
metadata:
name: my-topic
labels:
strimzi.io/cluster: my-cluster
spec:
replicas: 3
partitions: 12
---
apiVersion: kafka.strimzi.io/v1beta1
kind: KafkaTopic
metadata:
name: my-topic-reversed
labels:
strimzi.io/cluster: my-cluster
spec:
replicas: 3
partitions: 12
---
apiVersion: apps/v1
kind: Deployment
metadata:
labels:
app: java-kafka-producer
name: java-kafka-producer
spec:
replicas: 1
selector:
matchLabels:
app: java-kafka-producer
template:
metadata:
labels:
app: java-kafka-producer
spec:
containers:
- name: java-kafka-producer
image: quay.io/strimzi-examples/java-kafka-producer:latest
env:
- name: STRIMZI_TOPIC
value: my-topic
- name: STRIMZI_DELAY_MS
value: "1000"
- name: STRIMZI_LOG_LEVEL
value: "INFO"
- name: STRIMZI_MESSAGE_COUNT
value: "1000000"
- name: STRIMZI_TRACING_SYSTEM
value: opentelemetry
- name: KAFKA_BOOTSTRAP_SERVERS
value: my-cluster-kafka-bootstrap:9092
- name: KAFKA_KEY_SERIALIZER
value: "org.apache.kafka.common.serialization.StringSerializer"
- name: KAFKA_VALUE_SERIALIZER
value: "org.apache.kafka.common.serialization.StringSerializer"
- name: OTEL_SERVICE_NAME
value: kafka-otel
- name: OTEL_METRICS_EXPORTER
value: none
- name: OTEL_EXPORTER_OTLP_ENDPOINT
value: http://my-otlp-endpoint:4317
---
apiVersion: apps/v1
kind: Deployment
metadata:
labels:
app: java-kafka-streams
name: java-kafka-streams
spec:
replicas: 1
selector:
matchLabels:
app: java-kafka-streams
template:
metadata:
labels:
app: java-kafka-streams
spec:
containers:
- name: java-kafka-streams
image: quay.io/strimzi-examples/java-kafka-streams:latest
env:
- name: STRIMZI_SOURCE_TOPIC
value: my-topic
- name: STRIMZI_TARGET_TOPIC
value: my-topic-reversed
- name: STRIMZI_LOG_LEVEL
value: "INFO"
- name: STRIMZI_TRACING_SYSTEM
value: opentelemetry
- name: KAFKA_BOOTSTRAP_SERVERS
value: my-cluster-kafka-bootstrap:9092
- name: KAFKA_APPLICATION_ID
value: java-kafka-streams
- name: KAFKA_DEFAULT_COMMIT_INTERVAL_MS
value: "5000"
- name: KAFKA_DEFAULT_KEY_SERDE
value: "org.apache.kafka.common.serialization.Serdes$StringSerde"
- name: KAFKA_DEFAULT_VALUE_SERDE
value: "org.apache.kafka.common.serialization.Serdes$StringSerde"
- name: OTEL_SERVICE_NAME
value: kafka-otel
- name: OTEL_METRICS_EXPORTER
value: none
- name: OTEL_EXPORTER_OTLP_ENDPOINT
value: http://my-otlp-endpoint:4317
---
apiVersion: apps/v1
kind: Deployment
metadata:
labels:
app: java-kafka-consumer
name: java-kafka-consumer
spec:
replicas: 1
selector:
matchLabels:
app: java-kafka-consumer
template:
metadata:
labels:
app: java-kafka-consumer
spec:
containers:
- name: java-kafka-consumer
image: quay.io/strimzi-examples/java-kafka-consumer:latest
env:
- name: STRIMZI_TOPIC
value: my-topic-reversed
- name: STRIMZI_LOG_LEVEL
value: "INFO"
- name: STRIMZI_MESSAGE_COUNT
value: "1000000"
- name: STRIMZI_TRACING_SYSTEM
value: opentelemetry
- name: KAFKA_BOOTSTRAP_SERVERS
value: my-cluster-kafka-bootstrap:9092
- name: KAFKA_GROUP_ID
value: java-kafka-consumer
- name: KAFKA_KEY_DESERIALIZER
value: "org.apache.kafka.common.serialization.StringDeserializer"
- name: KAFKA_VALUE_DESERIALIZER
value: "org.apache.kafka.common.serialization.StringDeserializer"
- name: OTEL_SERVICE_NAME
value: kafka-otel
- name: OTEL_METRICS_EXPORTER
value: none
- name: OTEL_EXPORTER_OTLP_ENDPOINT
value: http://my-otlp-endpoint:4317