lsar">
  Flink &amp; Pulsar: Write data to Pulsar
  <a class="anchor" href="#flink--pulsar-write-data-to-pulsar">#</a>
</h1>
<ul>
<li>Create a Pulsar sink for streaming queries</li>
</ul>
<div class="highlight"><pre tabindex="0" class="chroma"><code class="language-java" data-lang="java"><span class="line"><span class="cl"><span class="n">val</span><span class="w"> </span><span class="n">env</span><span class="w"> </span><span class="o">=</span><span class="w"> </span><span class="n">StreamExecutionEnvironm