akkadotnet/Akka.Streams.Kafka

Issues

• Got unexpected Kafka message error

  #57 opened 5 years ago by IgorFedchenko
  8

• KafkaConsumer.CommittableSource strange error

  #396 opened 10 months ago by ManuSchm
  0

• `KafkaConsumerActor` should be public API

  #362 opened a year ago by ismaelhamed
  3

• Offsets not committing after recreating KafkaConsumerActor

  #338 opened 2 years ago by bezchristo
  1

• Failing to serialize/deserialize payload with serialize-messages = on

  #293 opened 2 years ago by bezchristo
  1

• KafkaConsumerActor fails to re-subscribe once restarted due to an exception

  #323 opened 2 years ago by bezchristo
  3

• Fix TransactionalProducer implementation once Confluent driver support this

  #85 opened 5 years ago by IgorFedchenko
  5

• NullRefException while reading a configuration

  #275 opened 3 years ago by devgopher
  0

• KafkaConsumerActor is consuming a lot of CPU

  #270 opened 3 years ago by Arkatufus
  0

• [PERF] Internal buffer size needs to be capped

  #242 opened 3 years ago by Aaronontheweb
  1

• Port all of the specs that we implemented from JVM

  #259 opened 3 years ago by Arkatufus
  0

• Need to look into some racy specs

  #258 opened 3 years ago by Arkatufus
  0

• Docs: need to explain how to skip poisoned message during Deserialization errors

  #253 opened 3 years ago by Aaronontheweb
  0

• Need to add "reasonable" default `Decider` to filter out hard failures from soft ones

  #252 opened 3 years ago by Aaronontheweb
  5

• Add setting to log non-fatal consumer/producer errors as warnings

  #195 opened 3 years ago by IgorFedchenko
  0

• CommitableSource consumer routed via FlexiFlow producer seemed to disconnect after awhile.

  #228 opened 3 years ago by Arkatufus
  10

• Error handling

  #73 opened 3 years ago by Eye-zz
  0

• Improve Kafka error handling

  #184 opened 3 years ago by Arkatufus
  6

• Re-creating SubSource for partition using the `KafkaConsumer.CommittablePartitionedSource` in parallel

  #232 opened 3 years ago by PugachA
  2

• SupervisionStrategy does not restart Akka.Streams.Kafka Sources when Downstream Fails

  #240 opened 3 years ago by Aaronontheweb
  7

• [CRITICAL] Need to stop polling for new messages when there is no downstream demand

  #245 opened 3 years ago by Aaronontheweb
  4

• Fishy spec in CommiterFlowIntegrationTests.cs

  #251 opened 3 years ago by Arkatufus
  0

• Plugin architecture need to be slowly redesigned to fix the inherent fragileness of the current implementation

  #248 opened 3 years ago by Arkatufus
  0

• Docs: need to include steps for enabling SASL authentication

  #239 opened 3 years ago by Aaronontheweb
  0

• Add Akka.Discovery support for locating Kafka Bootstrap servers

  #238 opened 3 years ago by Aaronontheweb
  0

• Akka Stream is consuming slow

  #209 opened 3 years ago by jsb81
  13

• SubSource might not be handling failure correctly.

  #220 opened 3 years ago by Arkatufus
  5

• Consumer does not handle partition assignment correctly

  #219 opened 3 years ago by Arkatufus
  1

• Add support for custom statistics handler

  #201 opened 3 years ago by hannesstockner
  4

• Add documentation about ConnectionChecker

  #191 opened 4 years ago by IgorFedchenko
  0

• DockerClient.Images.ListImagesAsync() could not use MatchName anymore.

  #179 opened 4 years ago by Arkatufus
  1

• How to apply further settings to the underlying kafka producer and consumer?

  #165 opened 4 years ago by realvictorprm
  2

• Kafka Stream stays in a "zombie" state although supervision strategy is to stop.

  #122 opened 4 years ago by realvictorprm
  3

• Broker: Unknown topic or partition after upgrading to kafka 1.5.0+

  #158 opened 4 years ago by IgorFedchenko
  1

• How can we get notified when a Kafka Consumer is rebalanced?

  #141 opened 4 years ago by ayoung
  15

• Add PartitionAssignmentHandler public API support

  #149 opened 4 years ago by IgorFedchenko
  0

• Consumer/Producer Settings Issue After Upgrading.

  #147 opened 4 years ago by Sherburn
  2

• Kafka in Azure Event Hub

  #148 opened 4 years ago by sleipnir
  7

• Why is "Key deserialization error" thrown

  #146 opened 4 years ago by hhko
  3

• Does not log exception when using DrainingControl

  #129 opened 5 years ago by ayoung
  5

• KafkaConsumer does not close on Stream Shutdown

  #130 opened 4 years ago by ayoung
  1

• How to use SourceWithOffsetContext with a RestartSource

  #132 opened 4 years ago by ayoung
  1

• Bug: InvalidOperationException

  #103 opened 5 years ago by Aaronontheweb
  0

• Support for Akka.net v1.3.16

  #94 opened 5 years ago by seungyongshim
  1

• Handle/fix "Got unexpected Kafka message" error

  #99 opened 5 years ago by IgorFedchenko
  0

• Implement CommittableSink of kafka producers

  #82 opened 5 years ago by IgorFedchenko
  0

• AtMostOnceSource_Should_stop_consuming_actor_when_used_with_Take test sometimes failes

  #74 opened 5 years ago by IgorFedchenko
  1

• AtMostOnceSource_Should_work test sometimes failing

  #66 opened 5 years ago by IgorFedchenko
  0

• Consumer actor does not perform proper incoming requests cleanup

  #58 opened 5 years ago by IgorFedchenko
  0

• Add test coverage for Pause/Resume partitions scenario

  #55 opened 5 years ago by IgorFedchenko
  0