我使用Kafka Rest代理来生成和使用Azure APIM从Kafka主题消费,因此使用Rest代理的原因。我可以使用auto.offset.reset =最早的线性方式使用消息,所以每次调用Kafka Rest都会给我最新的消息,这是很棒的,
在以下情况下:
A1 is data requestor
B2 is API that fulfills A1's request using REST proxy for Kafka
C3 is Kafka Rest proxy server
如果A1向B2请求数据,而B2使用卡夫卡主题C3提供的消息给A1,但由于某些互联网问题,该消息
在互联网上,我看到了很多关于Wait()和Pulse()的例子,他们使用了两个while,如下例所示:
class MyQueue
{
private Queue<string> queue = new Queue<string>();
private const int CAPACITY = 3;
public void Put(string element)
{
lock (this)
{
// first `while`
while (queue.Cou