FlinkKafkaConsumer09 not reading from all partitions?

2016-09-20 Thread Curtis Wilde
I’m just getting my feet wet with Flink, doing a quick implementation on my laptop following the examples. I’m consuming from a Kafka 0.9 cluster using FlinkKafkaConsumer09 from a topic with 50 partitions. I see offset commit messages for partitions 0-9, but I don’t see offsets being

REST Interface to JobManager

2016-09-22 Thread Curtis Wilde
I would like to be able to use Jenkins to deploy jobs to Flink. I’ve seen talk of a REST interface that might allow me to do this https://issues.apache.org/jira/browse/FLINK-1228 Is there any documentation around this feature?