Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/1489
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enab
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-173243638
I addressed all concerns and rebased to master.
Once the tests have passed, I'll merge the change.
---
If your project is set up for it, you can reply to this
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-172957450
I would leave a deprecated producer, just to make user's life easier...
---
If your project is set up for it, you can reply to this email and have your
reply appear
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-172932775
Thank you all for the comments. I renamed the Consumers again to include
the version, I added deprecated 081 and 092 consumers.
Do you think we should also add a dep
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-171933355
Are you sure it is a good idea to give the same name to the
producers/consumers for 0.8 and 0.9? Because now we have two
`org.apache.flink.streaming.connectors.kafka.Fl
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-171933036
I'm not sure because I don't know everything about it but why not rename
`KafkaServerProvider` to something that more clearly says what it is, like
`KafkaTestEnvironmen
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-171903718
Okay, I'll rename the consumers and producers to include the version.
(FlinkKafkaConsumer08 and so on.)
---
If your project is set up for it, you can reply to this ema
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-171741270
This PR changes the name of the KafkaConsumer classes. Both of them are now
called `FlinkKafkaConsumer` in the exact same namespace, and only differ in
their Maven p
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-171736931
We have not looked into how Kafka uses Kerberos, yet, so a ticket would be
good.
---
If your project is set up for it, you can reply to this email and have your
rep
Github user nielsbasjes commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-171665915
I read that Kafka 0.9 supports Kerberos authentication (I have not yet
tried this). Is that supported in this first release or should I open a Jira
ticket for that?
Github user rmetzger commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-170103132
There are some build instabilities with the new Kafka 0.9 code. I'll look
into it soon.
---
If your project is set up for it, you can reply to this email and have your
Github user tillrohrmann commented on the pull request:
https://github.com/apache/flink/pull/1489#issuecomment-170044651
Test cases `Kafka09ITCase.testMultipleSourcesOnePartition` and
`Kafka08ITCase.testOffsetInZookeeper` are failing in Travis build.
---
If your project is set up for
GitHub user rmetzger opened a pull request:
https://github.com/apache/flink/pull/1489
[FLINK-3058] Add support for Kafka 0.9.0.0
For adding Kafka 0.9.0.0 support, this commit changes the following:
- Split up of the kafka connector into a
flink-connector-kafka-(base|0.9|0.8) wit
13 matches
Mail list logo
