GitHub user lhotari edited a comment on the discussion: Is RabbitMQ source connectors safe?
@fabrizziocht Thanks for pointing out the issue. The Record interface has [an ack method](https://github.com/apache/pulsar/blob/54f0ca1c769638000fbeb4d73a565216c0992c32/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Record.java#L106-L110) which is where the acknowledgement to the source (RabbitMQ in this case) should be made. Would you like to create an issue report at https://github.com/apache/pulsar/issues to track addressing this problem? GitHub link: https://github.com/apache/pulsar/discussions/23677#discussioncomment-11458232 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
