Github user markap14 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/131#discussion_r45687909
--- Diff:
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java
---
@@ -70,6 +70,10 @@
+ " the message does not have a key, or if the batch size
is greater than 1, this attribute will not be added"),
@WritesAttribute(attribute = "kafka.partition", description = "The
partition of the Kafka Topic from which the message was received. This
attribute is added only if the batch size is 1"),
@WritesAttribute(attribute = "kafka.offset", description = "The
offset of the message within the Kafka partition. This attribute is added only
if the batch size is 1")})
+@DynamicProperty(name = "The name of a Kafka configuration property.",
value = "The value of a given Kafka configuration property.", description =
"These properties will be added on the Kafka configuration after loading any
provided configuration properties."
--- End diff --
@olegz this line is 260 characters; fails contrib-check. Can you break that
line apart?
---
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 enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
