Skip to content

Commit

Permalink
Merge pull request #247 from aliok/ali-kafka
Browse files Browse the repository at this point in the history
Knative Kafka related fixes
  • Loading branch information
kameshsampath authored Nov 10, 2020
2 parents c3abca7 + 7da55f1 commit 69eddd9
Show file tree
Hide file tree
Showing 6 changed files with 11 additions and 6 deletions.
5 changes: 4 additions & 1 deletion bin/clean-completed.sh
Original file line number Diff line number Diff line change
@@ -1,4 +1,7 @@
#!/bin/bash

echo "Deleting completed pods"
kubectl delete pods --field-selector=status.phase=Succeeded
kubectl delete pods --field-selector=status.phase=Failed

echo "Deleting failed pods"
kubectl delete pods --field-selector=status.phase=Failed
2 changes: 1 addition & 1 deletion bin/kafka-list-topics.sh
Original file line number Diff line number Diff line change
Expand Up @@ -11,4 +11,4 @@ kubectl exec -it "$KAFKA_CLUSTER_NAME-kafka-0" \
-n $KAFKA_CLUSTER_NS \
-- ./bin/kafka-topics.sh \
--list \
--zookeeper localhost:2181
--bootstrap-server localhost:9092
Original file line number Diff line number Diff line change
Expand Up @@ -58,8 +58,8 @@ kn channel -n {tutorial-namespace} ls
[.console-output]
[source,bash]
----
NAME TYPE URL AGE READY REASON
my-events-ch InMemoryChannel http://my-events-ch-kn-channel.knativetutorial.svc.cluster.local 10m True
NAME TYPE URL AGE READY REASON
my-events-ch KafkaChannel http://my-events-ch-kn-channel.knativetutorial.svc.cluster.local 2m55s True
----
--
{kubernetes-cli}::
Expand Down
2 changes: 2 additions & 0 deletions documentation/modules/advanced/pages/deploy-apache-kafka.adoc
Original file line number Diff line number Diff line change
Expand Up @@ -105,6 +105,8 @@ NAME READY STATUS AGE
my-cluster-entity-operator-7d677bdf7b-jpws7 3/3 Running 85s
my-cluster-kafka-0 2/2 Running 110s
my-cluster-zookeeper-0 2/2 Running 2m22s
my-cluster-zookeeper-1 2/2 Running 2m22s
my-cluster-zookeeper-2 2/2 Running 2m22s
strimzi-cluster-operator-85f596bfc7-7dgds 1/1 Running 4m22s
----

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -231,7 +231,7 @@ Create a `KafkaSource` for `my-topic` by connecting your Kafka topic `my-topic`

[source,yaml]
----
apiVersion: sources.knative.dev/v1alpha1
apiVersion: sources.knative.dev/v1beta1
kind: KafkaSource
metadata:
name: mykafka-source
Expand Down
2 changes: 1 addition & 1 deletion eventing/mykafka-source.yaml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
apiVersion: sources.knative.dev/v1alpha1
apiVersion: sources.knative.dev/v1beta1
kind: KafkaSource
metadata:
name: mykafka-source
Expand Down

0 comments on commit 69eddd9

Please sign in to comment.