Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
  • Loading branch information
mabulgu committed Jun 25, 2021
2 parents 60ca4cb + 44c1689 commit eb0c3bf
Showing 1 changed file with 2 additions and 4 deletions.
6 changes: 2 additions & 4 deletions examples/5_connect/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -395,9 +395,7 @@ $ watch "curl -s http://_ELASTIC_EXTERNAL_URL_/tweets/_search | jq -r '.hits.tot
In another terminal window you can run the console consumer again to see both the Twitter Source connector and the Camel Elasticsearch Sink connector in action:
<!---
Image here
-->
![tweets_flowing](https://user-images.githubusercontent.com/10568159/123325803-25480700-d541-11eb-9a6b-0028ea2cfada.png)
In a browser or with curl, call the following URl for searching `Apache` word in the tweet texts.
Expand Down Expand Up @@ -474,4 +472,4 @@ Congratulations!
In this example we are able to create a Kafka Connect cluster along with a Twitter Source connector with Strimzi Kafka CLI, to consume the tweets from Twitter and write them to one of our topics that we defined in the configuration.
We also altered the Kafka Connect Cluster and added new plugin resources for Camel Elasticsearch REST Sink connector, to write our tweets from the relevant topic to an Elasticsearch index with a single `--alter` command of Strimzi Kafka CLI.
This made our consumed tweets searchable, so that we could search for the word `Apache` in our `tweets` Elasticsearch index.
After finishing the example, we cleared up our resources by deleting them easily with the CLI.
After finishing the example, we cleared up our resources by deleting them easily with the CLI.

0 comments on commit eb0c3bf

Please sign in to comment.