IBMStreams/streamsx.messaging
This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.
JavaApache-2.0
Issues
- 0
- 5
Error: Could not find or load main class org.apache.log4j.net.JMSSink Caused by: java.lang.NoClassDefFoundError: javax/jms/MessageListener
#360 opened by sidhharth-developer - 0
- 21
- 4
KafkaConsumer start point in a consistent region?
#262 opened by ddebrunner - 7
- 4
Fused KafkaConsumer & KafkaProducer not working.
#279 opened by ddebrunner - 5
Provide simple integration with MessageHub.
#280 opened by ddebrunner - 2
- 2
- 4
- 13
KafkaProducer does not guarantee at least once message delivery in consistent region
#284 opened by ddebrunner - 3
KafkaConsumer doesn't enforce checkpointing rules outside of the consistent region
#288 opened by Alex-Cook4 - 2
KafkaConsumer does not guarantee at least once message processing in consistent region
#290 opened by ddebrunner - 3
Proposal: Allow KafkaConsumer to load its initial offsets from an external location.
#291 opened by ddebrunner - 3
- 1
- 1
Allow for integer keys in Kafka Consumer/Producer
#308 opened by Alex-Cook4 - 1
- 4
- 1
MQTTSink need to handle CR upon exception
#285 opened by chanskw - 10
MQTT reconnectionBound behaviour incorrect.
#312 opened by ddebrunner - 5
Nats.io support request
#330 opened by nicknezis - 1
please remove the master branch
#363 opened by markheger - 1
- 0
Security issue CVE-2017-12610
#352 opened by schubon - 1
com.rabbitmq:amqp-client vulnerability found in com.ibm.streamsx.messaging/pom.xml
#348 opened by schubon - 1
Globalizing the toolkit
#274 opened by gertmark - 1
- 1
- 4
NLS Work Review and Suggestions
#302 opened by chanskw - 1
- 4
Deprecate Kafka operators
#316 opened by cancilla - 1
Deprecate MQTT operators
#335 opened - 1
Deprecate RabbitMQ operators
#336 opened by schubon - 4
- 3
javax.management.InstanceAlreadyExistsException: kafka.consumer:type=consumer-node-metrics,client-id=consumer-1,node-id=node--4
#333 opened by sunruns - 10
closed.please ignore this issue.
#331 opened by sunruns - 3
Please ignore this issue; closed.
#332 opened by sunruns - 0
JMSSource ignores silently messages
#325 opened - 3
Doc: JMS operators don't explain whether they support at-least-once or exactly-once
#314 opened by Alex-Cook4 - 1
- 4
MessageHub sample and documentation need update
#306 opened by chanskw - 3
Nominate @cancilla as committer to streamsx.messaging
#300 opened by chanskw - 0
- 0
- 2
- 3
KafkaConsumer threadsPerTopic parameter?
#265 opened by ddebrunner - 3
Question: 5.1 release only 4.2?
#266 opened by ddebrunner - 1