">&lt;</span><span class="n">String</span><span class="o">&gt;</span><span class="w"> </span><span class="n">words</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">env</span><span class="p">.</span><span class="na">addSource</span><span class="p">(</span><span class="n">src</span><span class="p">);</span><span class="w">
</span></span></span></code></pre></div><p>Pulsar streams can then get connected to the Flink processing logic…</p>
<div class="highlight"><pr