knative
/
docs
mirror of https://github.com/knative/docs.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fixing Apache Kafka Even Source and Verify Sections (#2530)

This commit is contained in:
Shashankft9 2020-06-04 23:05:18 +05:30 committed by GitHub
parent 5458bef4d4
commit 1476081006
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 34 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
docs/eventing/samples/kafka/source/README.md
View File

@ -129,7 +129,7 @@ Tutorial on how to build and deploy a `KafkaSource` [Eventing source](../../../s
configuration. configuration.
``` ```
$ kubectl logs --selector='knative-eventing-source-name=kafka-source' $ kubectl logs --selector='knative-eventing-source-name=kafka-source'
{"level":"info","ts":"2019-04-01T19:09:32.164Z","caller":"receive_adapter/main.go:97","msg":"Starting Apache Kafka Receive Adapter...","Bootstrap Server":"...","Topics":".","ConsumerGroup":"...","SinkURI":"...","TLS":false} {"level":"info","ts":"2020-05-28T10:39:42.104Z","caller":"adapter/adapter.go:81","msg":"Starting with config: ","Topics":".","ConsumerGroup":"...","SinkURI":"...","Name":".","Namespace":"."}
``` ```
### Verify ### Verify
@ -142,14 +142,42 @@ Tutorial on how to build and deploy a `KafkaSource` [Eventing source](../../../s
>{"msg": "This is a test!"} >{"msg": "This is a test!"}
``` ```
1. Check that the Apache Kafka Event Source consumed the message and sent it to 1. Check that the Apache Kafka Event Source consumed the message and sent it to
its sink properly. its sink properly. Since these logs are captured in debug level, edit the key `level` of `config-logging` configmap in `knative-sources` namespace to look like this:
```
data:
loglevel.controller: info
loglevel.webhook: info
zap-logger-config: |
{
"level": "debug",
"development": false,
"outputPaths": ["stdout"],
"errorOutputPaths": ["stderr"],
"encoding": "json",
"encoderConfig": {
"timeKey": "ts",
"levelKey": "level",
"nameKey": "logger",
"callerKey": "caller",
"messageKey": "msg",
"stacktraceKey": "stacktrace",
"lineEnding": "",
"levelEncoder": "",
"timeEncoder": "iso8601",
"durationEncoder": "",
"callerEncoder": ""
}
}
```
Now manually delete the kafkasource deployment and allow the `kafka-controller-manager` deployment running in `native-sources` namespace to redploy it. Debug level logs should be visible now.
``` ```
$ kubectl logs --selector='knative-eventing-source-name=kafka-source' $ kubectl logs --selector='knative-eventing-source-name=kafka-source'
... ...
{"level":"info","ts":"2019-04-15T20:37:24.702Z","caller":"receive_adapter/main.go:99","msg":"Starting Apache Kafka Receive Adapter...","bootstrap_server":"...","Topics":"knative-demo-topic","ConsumerGroup":"knative-group","SinkURI":"...","TLS":false}
{"level":"info","ts":"2019-04-15T20:37:24.702Z","caller":"adapter/adapter.go:100","msg":"Starting with config: ","bootstrap_server":"...","Topics":"knative-demo-topic","ConsumerGroup":"knative-group","SinkURI":"...","TLS":false} {"level":"debug","ts":"2020-05-28T10:40:29.400Z","caller":"kafka/consumer_handler.go:77","msg":"Message claimed","topic":".","value":"."}
{"level":"info","ts":1553034726.546107,"caller":"adapter/adapter.go:154","msg":"Successfully sent event to sink"} {"level":"debug","ts":"2020-05-28T10:40:31.722Z","caller":"kafka/consumer_handler.go:89","msg":"Message marked","topic":".","value":"."}
``` ```
1. Ensure the Event Display received the message sent to it by the Event Source. 1. Ensure the Event Display received the message sent to it by the Event Source.
@ -157,7 +185,7 @@ Tutorial on how to build and deploy a `KafkaSource` [Eventing source](../../../s
``` ```
$ kubectl logs --selector='serving.knative.dev/service=event-display' -c user-container $ kubectl logs --selector='serving.knative.dev/service=event-display' -c user-container
☁️ cloudevents.Event ☁️ cloudevents.Eventi
Validation: valid Validation: valid
Context Attributes, Context Attributes,
specversion: 1.0 specversion: 1.0