[
https://issues.apache.org/jira/browse/NIFI-1218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060493#comment-15060493
]
ASF GitHub Bot commented on NIFI-1218:
--------------------------------------
Github user olegz commented on a diff in the pull request:
https://github.com/apache/nifi/pull/143#discussion_r47814729
--- Diff:
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/test/java/org/apache/nifi/processors/kafka/TestPutKafka.java
---
@@ -474,6 +475,18 @@ public void setStopFailingAfter(final Integer
stopFailingAfter) {
@Override
public void close() {
}
+
+ @Override
+ public void close(long arg0, TimeUnit arg1) {
+ // TODO Auto-generated method stub
+
+ }
+
+ @Override
+ public void flush() {
+ // TODO Auto-generated method stub
--- End diff --
As you can see, this is a MockProducer defined in test. Those two methods
are only there to comply with the changes in Kafka interface and are not part
of the test assertions.
> Upgrade Kafka modules to the latest Kafka release (0.9.0)
> ---------------------------------------------------------
>
> Key: NIFI-1218
> URL: https://issues.apache.org/jira/browse/NIFI-1218
> Project: Apache NiFi
> Issue Type: Task
> Affects Versions: 0.3.0
> Reporter: Oleg Zhurakousky
> Assignee: Oleg Zhurakousky
> Priority: Trivial
> Fix For: 0.5.0
>
>
> While at it see if embedded Kafka cluster code could be added to facilitate
> better testing since 0.9 actually looks more stable.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
