Timothy Spann
Timothy Spann
Is there a NiFi processor? I thought last time we talked, you had one. If not, maybe I'll take a look. Always love your libraries.
* Nipyapi version: 0.80 * NiFi version: 1.5 * NiFi-Registry version: 0.1 * Python version: 2.7, 3.4 * Operating System: Linux ### Description Add support to read and write all...
It would be nice to see a similar example for Apache Pulsar as the existing Apache Kafka one. Let me know if you need assistance.
**Is your feature request related to a problem? Please describe.** Confluent and Cloudera, and others have a REST API in a format integrated in several OTS apps. **Describe the solution...
**Is your feature request related to a problem? Please describe.** Add Pulsar as a Source. All the feature of Kafka. Pulsar also supports AMQP, MQTT, WebSockets, and Kafka as protocols....
[BUG]
**Describe the bug** Send fails on Pulsar 2.10.1 server as AOP/RabbitMQ libraries don't set a producer. **To Reproduce** send a message https://github.com/tspannhw/airquality/blob/main/src/main/java/dev/datainmotion/airquality/service/AMQPService.java **Expected behavior** messages sends to topic no error...
producer section #4 linked to Consumer class
Please add Apache Pulsar to the mix. Client (Python, Java, Golang, NodeJS) or server.
======== Input profiles ======== Profile host: [settings] arch=armv8 build_type=Release compiler=gcc compiler.cppstd=gnu17 compiler.libcxx=libstdc++11 compiler.version=12 os=Linux Profile build: [settings] arch=armv8 build_type=Release compiler=gcc compiler.cppstd=gnu17 compiler.libcxx=libstdc++11 compiler.version=12 os=Linux ERROR: Error loading conanfile at '/opt/demo/milvus-lite/conanfile.py':...
Add Milvus