6 Commits

Author	SHA1	Message	Date
Koji Kawamura	e5ed62a98f	NIFI-4724: Support 0 byte message with PublishKafka ... Before this fix, PublishKafka (0.9) and PublishKafka_0_10 fail with empty incoming FlowFiles due to 'transfer relationship not specified' error. Because the internal 'publish' method is not called as StreamDemarcator does not emit any token regardless whether demarcator is set or not. As for PublishKafka_0_11 and PublishKafka_1_0, empty FlowFiles are transferred to 'success' relationship, however no Kafka message is sent to Kafka. Since Kafka allows 0 byte body empty messages, NiFi should be able to send it, too. This commit changes above current situation to the followings, with all PublishKafka_* processors: - If demarcator is not set, then publish incoming FlowFile content as it is. This enables sending an empty Kafka message. - If demarcator is set, send each token as a separate message. Even if no token is found (empty incoming FlowFile), transfer the FlowFile to 'success'. This closes #2362. Signed-off-by: Mark Payne <markap14@hotmail.com>	2018-01-05 10:42:58 -05:00
jknulst	d543cfde25	NIFI-4675 Lifted restriction on demarcator and kafka.key usage together. This closes #2326.	2017-12-14 15:15:13 -05:00
Mark Payne	c138987bb4	NIFI-4656, NIFI-4680: This closes #2330. Fix error handling in consume/publish kafka processors. Address issue with HortonworksSchemaRegistry throwing RuntimeException when it should be IOException. Fixed bug in ConsumeerLease/ConsumKafkaRecord that caused it to report too many records received ... Signed-off-by: joewitt <joewitt@apache.org>	2017-12-08 16:01:14 -05:00
Mark Payne	113ad5ecfa	NIFI-4639: Updated PublishKafka 1.0 processor to use a fresh writer for each output record as well. This closes #2292.	2017-12-08 09:14:17 -05:00
joewitt	cdc1facf39	NIFI-4664, NIFI-4662, NIFI-4660, NIFI-4659 moved tests which are timing/threading/network dependent and brittle to integration tests and un-ignored tests that are IT. Updated travis to reduce impact on infra and appveyor now skips test runs so is just to prove build works on windows. This closes #2319 ... squash	2017-12-06 10:53:09 -05:00
Mark Payne	00b11e82b7	NIFI-4600: This closes #2312. Added nifi-kafka-1-0-nar and nifi-kafka-1-0-processors modules ... Signed-off-by: joewitt <joewitt@apache.org>	2017-12-04 16:51:59 -05:00