root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 5 Packages Projects Releases Wiki Activity

MINOR: Fix code listings in quickstart.html (#10767) 

* MINOR: Fix code listings in quickstart

Uses the right syntax highlighting

Reviewers: Mickael Maison <mickael.maison@gmail.com>, Luke Chen <showuon@gmail.com>
This commit is contained in:
Josep Prat 2024-02-05 16:43:53 +01:00 committed by GitHub
parent 829d5d45c4
commit f54975c331
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 14 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
docs/quickstart.html
View File

@ -173,8 +173,8 @@ Topic: quickstart-events TopicId: NPmZHyhbR9y00wMglMH2sg PartitionCount:
</p>
<pre class="line-numbers"><code class="language-bash">$ bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092
This is my first event
This is my second event</code></pre>
&gt;This is my first event
&gt;This is my second event</code></pre>
<p>
You can stop the producer client with <code>Ctrl-C</code> at any time.
@ -233,19 +233,16 @@ This is my second event</code></pre>
Edit the <code class="language-bash">config/connect-standalone.properties</code> file, add or change the <code>plugin.path</code> configuration property match the following, and save the file:
</p>
<pre class="brush: bash;">
&gt; echo "plugin.path=libs/connect-file-{{fullDotVersion}}.jar"</pre>
<pre class="line-numbers"><code class="language-bash">$ echo "plugin.path=libs/connect-file-{{fullDotVersion}}.jar &gt;&gt; config/connect-standalone.properties"</code></pre>
<p>
Then, start by creating some seed data to test with:
</p>
<pre class="brush: bash;">
&gt; echo -e "foo\nbar" > test.txt</pre>
<pre class="line-numbers"><code class="language-bash">$ echo -e "foo\nbar" &gt; test.txt</code></pre>
Or on Windows:
<pre class="brush: bash;">
&gt; echo foo> test.txt
&gt; echo bar>> test.txt</pre>
<pre class="line-numbers"><code class="language-bash">$ echo foo&gt; test.txt
$ echo bar&gt;&gt; test.txt</code></pre>
<p>
Next, we'll start two connectors running in <i>standalone</i> mode, which means they run in a single, local, dedicated
@ -255,8 +252,7 @@ This is my second event</code></pre>
class to instantiate, and any other configuration required by the connector.
</p>
<pre class="brush: bash;">
&gt; bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties</pre>
<pre class="line-numbers"><code class="language-bash">$ bin/connect-standalone.sh config/connect-standalone.properties config/connect-file-source.properties config/connect-file-sink.properties</code></pre>
<p>
These sample configuration files, included with Kafka, use the default local cluster configuration you started earlier
@ -273,10 +269,9 @@ This is my second event</code></pre>
</p>
<pre class="brush: bash;">
&gt; more test.sink.txt
<pre class="line-numbers"><code class="language-bash">$ more test.sink.txt
foo
bar</pre>
bar</code></pre>
<p>
Note that the data is being stored in the Kafka topic <code>connect-test</code>, so we can also run a console consumer to see the
@ -284,16 +279,14 @@ bar</pre>
</p>
<pre class="brush: bash;">
&gt; bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic connect-test --from-beginning
<pre class="line-numbers"><code class="language-bash">$ bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic connect-test --from-beginning
{"schema":{"type":"string","optional":false},"payload":"foo"}
{"schema":{"type":"string","optional":false},"payload":"bar"}
...</pre>
&hellip;</code></pre>
<p>The connectors continue to process data, so we can add data to the file and see it move through the pipeline:</p>
<pre class="brush: bash;">
&gt; echo Another line>> test.txt</pre>
<pre class="line-numbers"><code class="language-bash">$ echo Another line&gt;&gt; test.txt</code></pre>
<p>You should see the line appear in the console consumer output and in the sink file.</p>
@ -318,7 +311,7 @@ bar</pre>
<p>To give you a first taste, here's how one would implement the popular <code>WordCount</code> algorithm:</p>
<pre class="line-numbers"><code class="language-bash">KStream&lt;String, String&gt; textLines = builder.stream("quickstart-events");
<pre class="line-numbers"><code class="language-java">KStream&lt;String, String&gt; textLines = builder.stream("quickstart-events");
KTable&lt;String, Long&gt; wordCounts = textLines
.flatMapValues(line -&gt; Arrays.asList(line.toLowerCase().split(" ")))