Hi William
My experience with using the REST API to create RPG is that you must wait “some
time” before the port becomes available. A restart is not needed though.
My workaround is to repeatedly call GET on the RPG until the port becomes
available. It typically takes more than 10 seconds on a 5
Hi William
My experience with using the REST API to create RPG is that you must wait "some
time" before the port becomes available. A restart is not needed though.
My workaround is to repeatedly call GET on the RPG until the port becomes
available. It typically takes more than 10 seconds on a 5
The POST request that create an RPG returns an RemoteProcessGroupEntity whose
ID can be used to call GET repeatedly.
At some point you will find the port in
RemoteProcessGroupEntity.getComponent().getContents().getInputPorts() but not
immediately after creation.
-Original Message-
Hello
Is there a reason why JdbcCommon#createSchema creates an Avro schema with
nullable types for all fields?
Why not check with java.sql.ResultSetMetaData#isNullable ?
Hi
It seems you want to configure ConsumeKafka / ConsumeKafkaRecord for SASL_SSL
PLAIN. It is possible but not straightforward.
The "Kerberos Service Name" cannot be empty but its content does not matter
since it will not be used in this case.
The trick is to specify the 2 additional properties
Hi
Any reason why nifi-kafka-bundle is still bundled with kafka-clients-2.0.0.jar
and not a newer version?
Regards
Chris
Yes: https://issues.apache.org/jira/browse/KAFKA-9815
> we'd have to be sure the latest 2.x client also works well with all previous
> 2.x versions back to 2.0
I think kafka-clients should make sure of that.
The processors could still be named 2_0, it’s only the client jar that should
be the
