Skip to content

Instantly share code, notes, and snippets.

@awswithdotnet

awswithdotnet/KafkaMessageConsumer.cs

Created March 8, 2022 20:33
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save awswithdotnet/64acdb35fd9b1cbea0e240d18e24e2dc to your computer and use it in GitHub Desktop.
Save awswithdotnet/64acdb35fd9b1cbea0e240d18e24e2dc to your computer and use it in GitHub Desktop.
Download ZIP
kafka KafkaConsumer Consume Partial 2
Raw
KafkaMessageConsumer.cs
while (_isConsuming)
{
i++;
Console.WriteLine(i + ": ");
ConsumeResult<String, String> consumeResult = _consumer.Consume(_cts.Token);
Console.WriteLine(consumeResult.Message.Value);
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment