Ecosyste.ms: Issues

An open API service for providing issue and pull request metadata for open source projects.

GitHub / jet/FsKafka issues and pull requests

#95 - Target Confluent Kafka/librdkafka 1.9.2

Pull Request - State: closed - Opened by deviousasti over 2 years ago

#94 - Bump Newtonsoft.Json from 11.0.2 to 13.0.1 in /src/FsKafka

Pull Request - State: closed - Opened by dependabot[bot] over 2 years ago - 3 comments
Labels: dependencies

#93 - net6.0, DotNet.ReproducibleBuilds

Pull Request - State: closed - Opened by bartelink over 2 years ago

#92 - Sync AwaitTaskCorrect with canonical version

Pull Request - State: closed - Opened by bartelink over 2 years ago - 1 comment

#91 - Target CK/librdkafka 1.9.0

Pull Request - State: closed - Opened by bartelink over 3 years ago - 2 comments

#90 - Update Minver + SDK

Pull Request - State: closed - Opened by bartelink over 3 years ago

#89 - Finish up roadmap to 1.7.0

Pull Request - State: closed - Opened by deviousasti over 3 years ago - 1 comment

#88 - Remove targeting for Net 461

Pull Request - State: closed - Opened by deviousasti over 3 years ago

#87 - Remove Kafka0

Pull Request - State: closed - Opened by deviousasti over 3 years ago

#86 - Add header support for BatchedProducer

Pull Request - State: closed - Opened by deviousasti over 3 years ago - 7 comments

#85 - Target Confluent.Kafka 1.6.2, librdkafka 1.6.1

Pull Request - State: closed - Opened by bartelink almost 4 years ago

#84 - Add ProducerConfig maxMessageBytes

Pull Request - State: closed - Opened by bartelink about 4 years ago

#83 - Add AwaitWithStopOnCancellation

Pull Request - State: closed - Opened by bartelink about 4 years ago - 1 comment

#82 - Target Confluent.Kafka/librdkafka 1.5.3

Pull Request - State: closed - Opened by bartelink about 4 years ago

#81 - Remove extraneous Flush ?

Issue - State: open - Opened by bartelink about 4 years ago

#80 - Target Confluent.Kafka / librdkafka 1.5.2

Pull Request - State: closed - Opened by bartelink over 4 years ago

#79 - Fix memory leak in tail recursion

Pull Request - State: closed - Opened by wantastic84 over 4 years ago - 1 comment

#78 - Adding exception logging for consumer's batch processing loop

Pull Request - State: closed - Opened by wantastic84 over 4 years ago - 1 comment

#77 - Add mechanism to tear down KafkaMonitor threads

Pull Request - State: closed - Opened by wantastic84 over 4 years ago - 1 comment

#76 - Adding FsKafka.Monitor to integration tests

Pull Request - State: closed - Opened by wantastic84 over 4 years ago - 1 comment

#75 - Integration test fix : trying sequential calls for producer

Pull Request - State: closed - Opened by wantastic84 over 4 years ago

#73 - Remove deprecated; clean InFlightMessageCounter.AwaitThreshold

Pull Request - State: closed - Opened by bartelink over 4 years ago

#72 - Change maxInFlight units from GB to MB

Pull Request - State: closed - Opened by bartelink over 4 years ago - 1 comment

#71 - Implement KafkaProducerConfig.allowAutoCreateTopics

Pull Request - State: closed - Opened by bartelink over 4 years ago - 1 comment

#70 - Use Pause/Resume when pausing polling

Pull Request - State: closed - Opened by bartelink over 4 years ago - 1 comment

#69 - Expose default values of optional consumer params

Pull Request - State: closed - Opened by xandkar over 4 years ago - 2 comments

#68 - Encapsulate linger/batching semantics

Pull Request - State: closed - Opened by bartelink over 4 years ago

#67 - FsKafka0: Align MaxInFlight Sleep with FsKafka

Pull Request - State: closed - Opened by bartelink over 4 years ago

#66 - Target Confluent.Kafka/librdkafka.redist 1.5.0

Pull Request - State: closed - Opened by bartelink over 4 years ago

#65 - Check linger settings for upgrading to CK 1.5 dependency

Issue - State: closed - Opened by bartelink over 4 years ago

#64 - Adding batched consumer examples

Pull Request - State: closed - Opened by wantastic84 over 4 years ago - 2 comments

#62 - A minimal consumer sample would be helpful

Issue - State: closed - Opened by KoenigLear over 4 years ago - 1 comment
Labels: enhancement, help wanted, good first issue

#61 - Handle cancellation in InFlightMessageCounter.AwaitThreshold

Pull Request - State: closed - Opened by bartelink over 4 years ago - 2 comments

#60 - FsKafka0: Fix to handle Stop+Dispose cleanly

Pull Request - State: closed - Opened by bartelink over 4 years ago

#59 - FsKafka0: Fix tail recursion leak do!->return!

Pull Request - State: closed - Opened by bartelink over 4 years ago

#58 - Logging updates for handling consumer errors

Pull Request - State: closed - Opened by svairagade over 4 years ago - 1 comment

#57 - Tweak logging

Pull Request - State: closed - Opened by bartelink over 4 years ago

#56 - FsKafka0 shimming tweaks

Pull Request - State: closed - Opened by bartelink over 4 years ago

#55 - FsKafka0 cleanup for 1.5.0 beta.2

Pull Request - State: closed - Opened by bartelink over 4 years ago

#54 - FsKafka0 Integration fixes

Pull Request - State: closed - Opened by bartelink over 4 years ago

#53 - Target Confluent.Kafka/librdkafka.redist 1.4.2

Pull Request - State: closed - Opened by bartelink over 4 years ago

#52 - Add/Change KafkaConsumer/ProducerConfig autoOffsetReset, requestTimeout

Pull Request - State: closed - Opened by bartelink over 4 years ago

#51 - Add FsKafka0, KafkaMonitor

Pull Request - State: closed - Opened by bartelink over 4 years ago

#50 - Add ProduceAsync overloads for headers, raw messages

Pull Request - State: closed - Opened by bartelink almost 5 years ago

#49 - Change broker to bootstrapServers

Pull Request - State: closed - Opened by bartelink almost 5 years ago

#48 - V1.7.0 checklist

Issue - State: closed - Opened by bartelink about 5 years ago - 1 comment

#47 - minimal example

Pull Request - State: closed - Opened by dzmitry-lahoda about 5 years ago - 4 comments

#46 - minimal example (kafking from Notebook:) )

Pull Request - State: closed - Opened by dzmitry-lahoda about 5 years ago - 1 comment

#45 - Rename offetCommitIntervalMs to AutoCommitIntervalMs

Pull Request - State: closed - Opened by bartelink over 5 years ago

#44 - Target Confluent.Kafka 1.2.0

Pull Request - State: closed - Opened by bartelink over 5 years ago - 3 comments

#42 - Target CK/librdkafka.redist 1.1.0

Pull Request - State: closed - Opened by bartelink over 5 years ago

#41 - Monitor WIP

Pull Request - State: closed - Opened by bartelink over 5 years ago - 2 comments

#40 - Fix MessageMaxBytes defaulting

Pull Request - State: closed - Opened by bartelink over 5 years ago

#39 - Fix tail recursion leak

Pull Request - State: closed - Opened by bartelink over 5 years ago

#38 - Add Eventstore source

Pull Request - State: closed - Opened by bartelink over 5 years ago - 1 comment

#37 - Add EventStoreSource

Pull Request - State: closed - Opened by bartelink over 5 years ago

#36 - Add ParallelProducer

Pull Request - State: closed - Opened by bartelink over 5 years ago

#35 - Add StreamsProducer + StreamsConsumer

Pull Request - State: closed - Opened by bartelink over 5 years ago

#34 - Split ParallelConsumer out to Propulsion+Propulsion.Kafka

Pull Request - State: closed - Opened by bartelink over 5 years ago

#33 - Add Parallel Consumer

Pull Request - State: closed - Opened by bartelink over 5 years ago

#32 - Add way to filter InFlightMessageCounter re #31

Pull Request - State: closed - Opened by bartelink over 5 years ago

#31 - Proposal. `Consumer reached in-flight message threshold` too spamy

Issue - State: closed - Opened by Szer over 5 years ago

#30 - Split Batching impls out to own types; make defaults less surprising

Pull Request - State: closed - Opened by bartelink over 5 years ago

#29 - Pre 1.0 API cleanup

Pull Request - State: closed - Opened by bartelink over 5 years ago

#28 - custom attributes in consumer config now seq again

Pull Request - State: closed - Opened by Szer over 5 years ago - 2 comments

#27 - KafkaConsumerConfig expecting list as custom argument

Issue - State: closed - Opened by Szer over 5 years ago
Labels: v1.x

#26 - Why consumer is key=string, value=string?

Issue - State: closed - Opened by vasily-kirichenko almost 6 years ago - 2 comments

#25 - Correctly handle config with empty debug flags

Pull Request - State: closed - Opened by jgardella almost 6 years ago - 1 comment

#24 - Target Confluent.Kafka 1.0.0-RC3; use CompressionType

Pull Request - State: closed - Opened by bartelink almost 6 years ago

#23 - Target CK 1.0.0rc2+rdkafka 1.0.0

Pull Request - State: closed - Opened by bartelink almost 6 years ago

#22 - v1.x doesnt pin `Confluent.Kafka` and `librdkafka.redist`

Issue - State: closed - Opened by enricosada almost 6 years ago
Labels: bug, v1.x

#21 - Target Confluent.Kafka 1.0.0-RC1

Pull Request - State: closed - Opened by bartelink almost 6 years ago

#20 - save offsets when calling streamBuffered

Pull Request - State: closed - Opened by michaelliao5 almost 6 years ago - 1 comment

#19 - offsetRange fails when topic does not exist

Issue - State: closed - Opened by vchekan about 6 years ago - 1 comment

#18 - pin deps

Pull Request - State: closed - Opened by enricosada over 6 years ago

#17 - pin confluence deps in nupkg

Pull Request - State: closed - Opened by enricosada over 6 years ago

#16 - Set up CI with Azure Pipelines

Pull Request - State: closed - Opened by enricosada over 6 years ago

#15 - added invalid offset constant

Pull Request - State: closed - Opened by michaelliao5 over 6 years ago

#14 - The semantic of ProduceBatched in Legacy module should be the same as the one in Kafunk

Issue - State: closed - Opened by dongdongcai over 6 years ago - 1 comment
Labels: bug, v0.9.x

#13 - added kafunk legacy module ConsumerInfo

Pull Request - State: closed - Opened by michaelliao5 over 6 years ago - 2 comments

#12 - Use reflection to get config DU case labels

Pull Request - State: closed - Opened by chrnola over 6 years ago

#11 - Make sure that offsets are not GC-ed if consumer experience no traffic for long time

Issue - State: closed - Opened by vchekan over 6 years ago - 8 comments
Labels: v0.9.x

#10 - Fix eager offset storage bug

Pull Request - State: closed - Opened by chrnola over 6 years ago - 1 comment
Labels: bug

#9 - Decide which tests are needed and implement

Issue - State: closed - Opened by vchekan over 6 years ago - 6 comments
Labels: v0.9.x

#8 - Integrate tests into CI

Issue - State: closed - Opened by vchekan over 6 years ago - 1 comment

#7 - Consumer without joining a group

Issue - State: closed - Opened by vchekan over 6 years ago - 1 comment
Labels: v0.9.x

#6 - QueryWatermarkOffsets queries one partition at the time

Issue - State: closed - Opened by vchekan over 6 years ago - 1 comment
Labels: v0.9.x

#5 - Implement instrumentation

Issue - State: closed - Opened by vchekan over 6 years ago - 1 comment
Labels: v0.9.x

#4 - Solve blocking producer buffer problem

Issue - State: closed - Opened by vchekan over 6 years ago - 1 comment
Labels: v0.9.x

#3 - Add statisctics integration

Issue - State: closed - Opened by vchekan over 6 years ago - 1 comment
Labels: v0.9.x

#2 - Wrapper introduce NLog dependency

Issue - State: closed - Opened by vchekan over 6 years ago - 4 comments

#1 - Change licence to Apache

Pull Request - State: closed - Opened by vchekan over 6 years ago - 2 comments