バイナリ配布物に含まれていないモジュールとのリンク

バイナリ配布は、配布プログラムのクラスパスへ自動的に配布されるlibフォルダ内にjarパッケージを含みます。ほとんど全てのFlinkクラスは、例えばストリーミングコネクタといくつかの新しく追加されたモジュールの2,3の例外を除いてそこにあります。これらのモジュールに依存するコードを実行するには、実行時にそれらにアクセス可能にする必要があります。以下の二つのオプションはそれらを示唆します:

jarファイルを全てのタスクマネージャー上のlib フォルダにコピーする。この後でタスクマネージャーを再起動する必要があることに注意してください。
あるいは、それらをコードと一緒にパッケージ化する。

後者のバージョンはFlinkでのクラスローダーの管理を尊重するため、お勧めです。

Mavenを使ったユーザコードとの依存物のパッケージ

Flinkによって含まれないこれらの依存を提供するために、Mavenを使った二つのオプションを提案します。

mavenアセンブリプラグインは全ての依存を含むuber-jar (実行可能jar)と呼ばれるものをビルドします。アセンブリ設定は簡単ですが、結果のjarは嵩張ったものになるかも知れません。更に詳しい情報はmaven-assembly-pluginを見てください。
maven unpack プラグインは、依存物の関係する部分を解凍し、それをあなたのコードと一緒にパッケージ化します。

Using the latter approach in order to bundle the Kafka connector, flink-connector-kafka you would need to add the classes from both the connector and the Kafka API itself. プラグインのセクションに以下を追加します:

<plugin>
    <groupId>org.apache.maven.plugins</groupId>
    <artifactId>maven-dependency-plugin</artifactId>
    <version>2.9</version>
    <executions>
        <execution>
            <id>unpack</id>
            <!-- executed just before the package phase -->
            <phase>prepare-package</phase>
            <goals>
                <goal>unpack</goal>
            </goals>
            <configuration>
                <artifactItems>
                    <!-- For Flink connector classes -->
                    <artifactItem>
                        <groupId>org.apache.flink</groupId>
                        <artifactId>flink-connector-kafka</artifactId>
                        <version>1.3-SNAPSHOT</version>
                        <type>jar</type>
                        <overWrite>false</overWrite>
                        <outputDirectory>${project.build.directory}/classes</outputDirectory>
                        <includes>org/apache/flink/**</includes>
                    </artifactItem>
                    <!-- For Kafka API classes -->
                    <artifactItem>
                        <groupId>org.apache.kafka</groupId>
                        <artifactId>kafka_<YOUR_SCALA_VERSION></artifactId>
                        <version><YOUR_KAFKA_VERSION></version>
                        <type>jar</type>
                        <overWrite>false</overWrite>
                        <outputDirectory>${project.build.directory}/classes</outputDirectory>
                        <includes>kafka/**</includes>
                    </artifactItem>
                </artifactItems>
            </configuration>
        </execution>
    </executions>
</plugin>

これで、mvn clean package を実行する時に、生成されたjarは必要とする依存を含みます。