如果我使用 kafka-jms-client 不支持的功能,kafka 会如何响应?

What will kafka respond if I use features that kafka-jms-client doesn't support?

我想使用 kafka-jms-client 来替换我当前的 jms 代理。根据 documentation,不支持某些功能,例如提交或回滚。当客户端调用提交或回滚时会发生什么? API 是否只是简单地响应 OK 但实际上在 Kafka 方面没有做任何事情?

查看源代码后发现,Kafka JMS 客户端的 javax.jms.Session.commit()javax.jms.Session.rollback() 实现什么都不做。

Here's the implementation for rollback(), and here's the implementation for commit() (which invokes commit() on KafkaMessageConsumer)。正如您所看到的,这两种方法最终什么都不做。他们会 return 好像一切正​​常。

javax.jms.Session 实现中的许多其他方法都遵循相同的模式。