如果我使用 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
实现中的许多其他方法都遵循相同的模式。
我想使用 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
实现中的许多其他方法都遵循相同的模式。