lovoo/goka

Issues

• Handling Panic in ctx.Lookup Caused by ctx.Fail in Goka Library

  #467 opened 2 months ago by kevin-you2
  3

• View retrieval by key response times

  #466 opened 3 months ago by pfortin-urbn
  0

• Question: Trying to find the best way to join multiple topics

  #463 opened 4 months ago by Quinoa3
  1

• [Production Usage] Question: How can I modify the state of the whole table triggered by an input message?

  #462 opened 4 months ago by akshatraika-moment
  1

• Races detected in visitor code

  #461 opened 4 months ago by owenniles
  0

• produce message larger than configured Producer.MaxMessageBytes

  #460 opened 4 months ago by BhautikChudasama
  2

• Kafka broker outage takes down processor even though there are other active brokers

  #457 opened 5 months ago by akshatraika-moment
  1

• "panic: sync: negative WaitGroup counter" in PartitionProcessor.VisitValues

  #433 opened 6 months ago by akshatraika-moment
  9

• Thought experiment: Librdkafka-based lookup table producers

  #456 opened 6 months ago by owenniles
  0

• How to get Lookup tables to work with processors?

  #452 opened 7 months ago by akshatraika-moment
  0

• bug error setting up for partition

  #415 opened 8 months ago by kumin
  3

• Is there a way to get a list of the keys associated with a processor instance?

  #446 opened a year ago by oliviabarnett
  2

• Writing to group table from asynchronous function; using ctx.SetValue causes a WaitGroup panic

  #443 opened a year ago by dschreij
  0

• Configuring Sarama's initial offset to OffsetOldest leads the existing group to reprocess topic messages from start

  #441 opened a year ago by homier
  3

• LevelDB - No space left on device

  #432 opened a year ago by aditya-msd
  1

• no automatic reconnection processor ?

  #431 opened a year ago by liubaochuan
  1

• Behavior of View Sync

  #440 opened a year ago by aditya-msd
  1

• [question] Azure EventHub

  #430 opened a year ago by ghstahl
  1

• Convert to using github.com/IBM/sarama

  #428 opened a year ago by ghstahl
  1

• What storage I should use for processor and view?

  #424 opened a year ago by korrawit
  4

• How to fill up local cache with messages from a custom offset on start up?

  #425 opened a year ago by onkarbanerjee
  1

• How to modify value in Group table?

  #423 opened 2 years ago by korrawit
  4

• Kafka server: Message was too large, server rejected it to avoid allocation error

  #422 opened 2 years ago by aditya-msd
  3

• Pause and Resume Functionality in Processor

  #404 opened 2 years ago by johnmehan
  4

• EmitSync stuck in channel

  #417 opened 2 years ago by rockwithamoon
  3

• Cannot connect to broker if the program is on docker container

  #419 opened 2 years ago by alifmufthi91
  3

• how to use Goka to move data from group table state to different storage system

  #416 opened 2 years ago by devcorpio
  4

• Question: Goka compatibility with Kafka 3.3.1 (KRaft)

  #396 opened 2 years ago by Derek-Hardy
  1

• Any way allow to customize key of KTable

  #413 opened 2 years ago by kumin
  1

• Failing to run examples

  #395 opened 2 years ago by CG-SS
  6

• Question: Alternative for loop?

  #364 opened 2 years ago by chin8628
  3

• Link to blog post is dead

  #405 opened 2 years ago by rupurt
  1

• Bug: `PartitionProcessor.VisitValues` does not clean up `Signal.waiters`, causing a memory leak

  #398 opened 2 years ago by chrisfjones
  0

• Processor calls wrong decode codec on message receipt

  #407 opened 2 years ago by mrothroc
  1

• Question: Regarding Emitters Connection

  #399 opened 2 years ago by fahmyabdul
  2

• RedisIterator skips first key when it.Next() is called

  #394 opened 2 years ago by chrisfjones
  5

• ctx.Value() changes initial message

  #391 opened 2 years ago by merlor
  5

• The process is disconnected when Kafka restart

  #380 opened 3 years ago by aimin-git
  2

• Wiki references ZKTopicManagerBuilder but it doesn't exist

  #381 opened 3 years ago by robottheory
  1

• Goka set debug mode to custom logger

  #382 opened 3 years ago by MirkoGibin
  3

• create actions for examples

  #379 opened 3 years ago by frairon
  0

• check partition mismatch

  #378 opened 3 years ago by frairon
  0

• clean tests

  #377 opened 3 years ago by frairon
  0

• Stopping simultaneously fails

  #376 opened 3 years ago by frairon
  0

• topic manager should retry

  #375 opened 3 years ago by frairon
  0

• Question: Auto-commit?

  #369 opened 3 years ago by ryanolds-drizly
  8

• go get package failed

  #371 opened 3 years ago by ouranoshong
  1

• processing messages without keys

  #374 opened 3 years ago by mikedewar
  2

• Panic "concurrent map read and map write" in memory storage

  #355 opened 3 years ago by pachmu
  2

• improve error message for duplicate storage usage

  #362 opened 3 years ago by frairon
  0