ites a file for
> checkpoint/savepoint, in case of restart/crash this file must be accessible
> from other nodes after the restart.
>
> Piotrek
>
> On 5 Mar 2019, at 10:01, marzieh ghasemi
> wrote:
>
> Thank you for your reply.
>
> Yes, I followed this link.
>
>
> h
Thank you!
On Thu, Nov 15, 2018 at 4:18 PM Chesnay Schepler wrote:
> I'm highly encouraging you to read through the examples and Batch API
> documentation:
>
>
> https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/batch/#example-program
>
> https://ci.apache.org/projects/flink/flink-
nd the one your job assumes (0.8).
>
> You should use an older Kafka version (0.8) for the job to run
> out-of-the-box or update your job to use FlinkKafkaProducer011.
>
> Cheers,
> Kostas
>
> On Oct 6, 2018, at 2:13 PM, marzieh ghasemi
> wrote:
>
> Hello
>
>
Hello
I downloaded kafka and followed these instructions step by step:
cd kafka_2.11-2
# start zookeeper server
./bin/zookeeper-server-start.sh ./config/zookeeper.properties
# start broker
./bin/kafka-server-start.sh ./config/server.properties
# create topic “test”
./bin/kafka-topics.sh --cre
