Code

Fix reading from topics#10

Code

Merged

panaxging merged 8 commits intomasterpanaxging/nf-kafka:masterfrom fix/reading_topicspanaxging/nf-kafka:fix/reading_topicsCopy head branch name to clipboardJul 10, 2024

+53-15

Commits

Commits on Jul 10, 2024

• [reading_topics] fix:

  panaxging

  committed
  218d1ed

• [reading_topics] fix: 🐛 close the channel after consuming topic

  panaxging

  committed
  b5d8675

• [reading_topics] feat: ✨ add poll timeout

  panaxging

  committed
  c22ab44

• [reading_topics] fix: 🐛 parse pollTimeout as integer and throw exception if mandatory paramteres (url and group) aren't set

  panaxging

  committed
  20e6688

• [reading_topics] feat: ✨ retrieve pollTimeout from kafkaConf

  panaxging

  committed
  bfae593

• [reading_topics] docs: ✏️ fix typo

  panaxging

  committed
  90fd445

• [reading_topics] docs: 📝 update configuration section

  panaxging

  committed
  396738a

• [reading_topics] fix: 🐛 close the channel

  panaxging

  committed
  686bb5e