[
https://issues.apache.org/jira/browse/NIFI-2608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15435444#comment-15435444
]
Joseph Witt commented on NIFI-2608:
-----------------------------------
Fixed that we set whatever property we have on the kafka properties listing.
Now we check if the producer or consumer being used actually supports that
property.
Fixed that we didn't have 0.8, 0.9, and 0.10. We now support them all
directly. Refactored kafka module to reflect this.
Fixed NPE that existed due to pool handling.
Remaining:
- Add annotations to the baseconsumer and basepublish classes which covers the
flow file attributes it reads/writes
- Add docs explaining how to think about number of threads/etc.. for consumers
relative to topics/partitions being used.
> Align Consume Kafka with Kafka 0.9 unified API and support 0.10 clients
> -----------------------------------------------------------------------
>
> Key: NIFI-2608
> URL: https://issues.apache.org/jira/browse/NIFI-2608
> Project: Apache NiFi
> Issue Type: Bug
> Reporter: Oleg Zhurakousky
> Assignee: Joseph Witt
> Priority: Critical
> Fix For: 1.0.0
>
>
> KafkaConsumer went fro thread-safe in 0.8 to not-thread-safe in 0.9 which was
> overlooked while implementing new ConsumeKafka processor which relied on 0.9
> Client API.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
