Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add compat assertions #3

Closed
wants to merge 1,107 commits into from
Closed

add compat assertions #3

wants to merge 1,107 commits into from

Conversation

keirlawson
Copy link
Owner

  • fix problem with emitting same data from stream after rebalance: in some cases streams on same partitions never closed.
  • Add producer metrics
  • Move producer metrics method
  • Update sbt-header to 5.6.0
  • Update embedded-kafka to 2.4.1.1
  • Update sbt-mdoc to 2.2.0
  • Update kafka-avro-serializer to 5.4.2
  • Update vulcan to 1.1.0
  • Update kafka to 2.5.0
  • Update embedded-kafka to 2.5.0
  • Update sbt-header to 5.6.0
  • Update sbt-scalafmt to 2.4.0
  • Update sbt to 1.3.11
  • Update sbt to 1.3.12
  • Update sbt-mdoc to 2.2.1
  • Update sbt-mdoc to 2.2.2
  • Update sbt-mdoc to 2.2.3
  • Update sbt to 1.3.13
  • Update sbt-scalafmt to 2.4.2
  • Update sbt-mdoc to 2.2.4
  • Update sbt-scalafmt to 2.4.2
  • Update sbt-buildinfo to 0.10.0
  • Update sbt-mdoc to 2.2.5
  • Update scala to 2.13.3
  • Update depedencies to latest versions
  • Change to not rely on auto-application
  • Change to only track most recent partiton stream ids
  • Remove KafkaConsumer.Metrics as it's not needed
  • Add filter for binary compatibility check
  • Update fs2-core to 2.4.4
  • Update discipline-scalatest to 2.0.1
  • Update sbt-mdoc to 2.2.6
  • Update vulcan to 1.2.0
  • Update cats-effect-laws to 2.2.0
  • Update sbt-mdoc to 2.2.7
  • Update sbt-mdoc to 2.2.8
  • Update kafka-avro-serializer to 6.0.0
  • Update scala to 2.12.12
  • Preparation refactoring
  • KafkaConsumer#partitionsMapStream implementation
  • Revert scala 2.12 update to make build green again
  • Fix javax.ws.rs-api resolving issue
  • Fixing race conditions in the KafkaConsumerActor
  • Update sbt-mdoc to 2.2.10
  • Update sbt-mima-plugin to 0.8.1
  • Update sbt to 1.4.1
  • wip
  • fix cross-version stuff
  • Trying to fix tests
  • wip
  • bump cats-effect
  • wip
  • remove unneeded Parallel
  • dispatcher
  • provide IORuntime for tests
  • more work on tests
  • KafkaConsumer improvements
  • Refactoring, replace Synchronized with Semaphore
  • WithConsumer: suspend side effects directly with blocking
  • Use blocking at call site of withProducer
  • Add blocking method to withConsumer
  • cancelable KafkaFuture
  • Update fs2 version
  • use Dispatcher in KafkaProducer
  • Change to format sources
  • replace Synchronized with Semaphore, refactor WithConsumer
  • refactor WithProducer
  • race -> timeout
  • add blocking method to WithConsumer
  • update cats version
  • refactor nulls
  • Weaken Producer requirement from ConcurrentEffect to Effect
  • Added KafkaAdminClient methods alterConsumerGroupOffsets and deleteConsumerGroupOffsets
  • Use WithConsumer.blocking in KafkaConsumerActor
  • Add blocking to withProducer
  • Pass around callbacks rather than Deferred where possible in KafkaConsumerActor
  • use syntax for guarantee/bracket
  • Update WithProducer api, remove WithConsumer#apply
  • deduplicate WithProducer
  • mima exclusions
  • use asyncF rather than Deferred for offsetCommit in KafkaConsumerActor
  • use asyncF rather than Deferred for offsetCommit in KafkaConsumerActor
  • Add docs for KafkaConsumer#partitionedMapStream
  • use blocking only where needed
  • fix naming
  • Update sbt to 1.4.2
  • more refactoring
  • Update sbt-ci-release to 1.5.4
  • Update sbt-mdoc to 2.2.11
  • Bump Cats to 2.2.0
  • Update fs2-core to 2.4.5
  • wip
  • change position of context.shift
  • Update sbt-mdoc to 2.2.12
  • Decompose consumer into traits
  • Use context bounds for implicits
  • Update discipline-scalatest to 2.1.0
  • update MiMa exclusions
  • Update kind-projector to 0.11.1
  • Update sbt to 1.4.4
  • Add missing headers
  • add missing header
  • fix doc
  • Update fs2-core to 2.4.6
  • run scalafmt, remove unused imports from docs
  • Update sbt-mdoc to 2.2.13
  • KafkaProducer.Connection
  • consistent naming
  • scalafmt
  • Add prefixes to consumer trait names
  • rename KafkaConsumerFiber to KafkaConsumerLifecycle
  • seal Connection
  • Improve ergonomics of instantiating producers
  • Add KafkaProducer.Connection.stream
  • Remove unneeded use of .using syntax for instantiating consumers/producers
  • Update cats-effect-laws to 2.3.0
  • drop better-monadic-for
  • giving up on trying to get scaladocs to link properly
  • Rename + move KafkaProducer
  • Deprecate producerResource/producerStream etc in package object
  • Update kind-projector syntax
  • Syntax changes for scala 3 compatibility
  • Update kafka-avro-serializer to 6.0.1
  • Add test for KafkaProducerConnection
  • Change way to instantiate KafkaConsumer
  • Change syntax for instantiating TransactionalKafkaProducer
  • Change syntax for instantiating KafkaAdminClient
  • Update sbt-ci-release to 1.5.5
  • Added Traverse and Bitraverse instances to the CommittableConsumerRecord, CommittableProducerRecords, ConsumerRecord and ProducerRecord
    • Added Eq instances for: - Header - Headers - Timestamp - ConsumerRecord - ProducerRecord - CommittableOffset - CommittableConsumerRecord - CommittableProducerRecords - Deleted CatsEquality.scala and CatsSuite.scala in favor of cats-testkit-scalatest. - Added laws tests for all newly added Eq instances and - Added laws tests for Traverse/Bitraverse instances for: - CommittableConsumerRecord - CommittableProducerRecords - ConsumerRecord - ProducerRecord
  • Added stopConsuming method to the KafkaConsumer
  • Added commitSync and commitAsync methods to the KafkaConsumer
  • Change to switch from Travis to GitHub Actions
  • Update sbt to 1.4.5
  • Missing comma
  • Update sbt-mdoc to 2.2.14
  • Update cats-effect-laws to 2.3.1
  • Update discipline-scalatest to 2.1.1
  • Updates for dotty
  • fixes for scala 3 support
  • Update fs2-core to 2.5.0
  • Update sbt to 1.4.6
  • make KafkaConsumer object public
  • fix scaladoc
  • update docs
  • update copyright headers
  • add scaladocs for KafkaProducerConnection
  • Update deprecated usages
  • update deprecated usage, fix doc
  • Update copyright header
  • disable coverage
  • Update vulcan to 1.3.0
  • remove coverage, update dependencies
  • fix binary compatibility issue
  • Change order of type parameters in ProducerRecords
  • ignore ACLs test
  • set logging level in test to ERROR
  • scalafmt
  • Reorder type params in TransactionalProducerRecords
  • format build.sbt
  • Use github matrix for scala versions
  • remove duplication in ci
  • use github matrix for CI
  • start replacing embedded kafka with testcontainers
  • Remove duplication in ci
  • use testcontainers for KafkaConsumerSpec and TransactionalKafkaProducerSpec
  • wip
  • revert change to 2.12 patch version
  • use TestContainers for KafkaAdminClient
  • remove ci duplication
  • setup docker in ci
  • log at info level
  • fix scala 2.12 build, remove setup-docker from ci
  • set log level to info
  • use ForEachContainer for all tests
  • remove old BaseKafkaSpec, rename new one
  • Remove embedded kafka
  • clean up BaseKafkaSpec
  • update license
  • fix null pointer
  • update kafka version
  • change vals to defs
  • try increasing consume timeout
  • use default kafka conatiner version
  • update error type
  • filter out confluent-related topics in AdminClientSpec
  • change group / client id's, improve logging
  • fix test
  • Update kind-projector to 0.11.3
  • Revert "use github matrix for CI"
  • Use sbt-github-actions for ci
  • fix cond in ci
  • Make instances public, add fs2Kafka prefix to their names
  • Rename KafkaX type aliases to JavaX
  • disable artifact upload
  • remove coverage
  • remove coverage from validate
  • Revert "use github matrix for CI"
  • scalafmt
  • fix toString test
  • scalafmt
  • remove deprecated aliases
  • disable mima, remove exclusions
  • Add test for message ordering
  • Revert KafkaProducer change that broke message ordering
  • Temporarily hard-code mima to run against 1.1.0, remove no-longer-needed mima exclusions
  • use runAsync in KafkaProducer
  • cleanup after v1.3.0 release
  • update test
  • scalafmt
  • Add acknowledgement to BaseKafkaSpec
  • remove codecov badge from website
  • don't check bincompat for dotty
  • Set previous artifacts to none, remove old mima exclusions
  • fix dotty compiler errors
  • Add missing entry to publish env
  • remove obsolete comment
  • Update sbt-mdoc to 2.2.15
  • no message
  • fixing compiler errors
  • got KafkaConsumerActor compiling
  • scalafmt
  • dependency updates
  • make tests compile
  • fix ordering bug regression
  • Update sbt-github-actions to 0.10.1
  • Update sbt-github-actions to 0.10.1
  • Update jline to 2.14.6
  • Update sbt-mdoc to 2.2.16
  • Remove deprecated type aliases
  • add ScalaFix rules for deprecat package object methods
  • run scalafix
  • Run release-drafter against all series branches
  • Only draft releases for series/1.x
  • Update sbt-dotty to 0.5.2
  • Update cats-testkit-scalatest dependency
  • remove fiber
  • allow consumer shutdown
  • cleanup
  • Remove unneeded .void
  • Remove unneeded Functor
  • port CE2 fiber as FakeFiber
  • scalafmtSbt
  • Remove unused imports
  • Fix deprecations
  • Fix docs
  • Extract KafkaConsumer.spawn method
  • KafkaConsumerLifecycle: add terminate and awaitTermination methods
  • Mark KafkaConsumerLifecycle.fiber as deprecated
  • Remove usage of KafkaConsumerLifecycle.fiber in KafkaConsumerSpec
  • KafkaConsumerLifecycle: exclude new methods added
  • Minor refactoring
  • Rename spawn to spawnRepeating
  • KafkaConsumer calls fiber.join/cancel
  • Fixes for scala 3
  • Use awaitTermination instead of fiber.join
  • Rename KafkaX type aliases to JavaX
  • Make instances public, add fs2Kafka prefix to their names
  • KafkaConsumer: update definition of fiber, awaitTermination, terminate
  • Update sbt to 1.4.7
  • Use FakeFiber for terminate/awaitTermination
  • correct deprecation message for adminClientStream
  • Update testcontainers-scala-kafka, ... to 0.38.9
  • Update sbt-mdoc to 2.2.17
  • Revert changes to fiber logic
  • Fix binary compatibility issue
  • update scala 2.12 version
  • update github workflow
  • Update kafka-avro-serializer to 6.1.0
  • Update testcontainers-scala-kafka, ... to 0.39.0
  • Update cats-kernel-laws, cats-laws to 2.4.1
  • Update .mergify.yml
  • Update build.sbt
  • Amend KafkaConsumerLifecycle doc
  • Fix errors with @nowarn annotations
  • remove unneeded callback helper method
  • Cleaner workaround for @nowarn bug
  • Fix typo in .mergify.yml
  • Update vulcan to 1.4.0
  • Use snapshot versions of cats-effect and fs2
  • Update test imports
  • remove KafkaConsumer#fiber
  • refactoring fakefiber
  • Update testcontainers-scala-kafka, ... to 0.39.1
  • Simplify FakeFiber code
  • Move FakeFiber to separate file
  • Reinstate serde property tests
  • Reinstate most CommitRecovery tests
  • Fix CommitRecovery sleep test
  • Revert "Rename KafkaX type aliases to JavaX"
  • use Stream.fromQueueNoneTerminated
  • remove redundant braces
  • Update build.sbt
  • Add comment to FakeFiber
  • Fix compiler warnings
  • Update to CE3 RC1, latest fs2 milestone
  • Remove mima exclusions in 2.x
  • simplify pattern match
  • Refactor resource allocation in TransactionalKafkaProducer to reduce depth of nesting
  • Create KafkaCredentialStore
  • Add certificates.md
  • certificates.md: add title and id
  • certificates.md: fix docs using fromString methods
  • Add headers
  • scalafmt
  • Update docs/src/main/mdoc/certificates.md
  • use Stream.fromQueueUnterminated
  • Remove minor differences with 2.x
  • Update certificates.md
  • fix merge mistake
  • Use Stream.fromQueue
  • Code review comments
  • fix Future.cancelable op
  • Bump fs2 to 3.0.0-M8
  • Add KafkaCredentialStore.createFromStrings
  • Add withCredentials(credentialsStore: KafkaCredentialStore) method to *Settings
  • Fix certificates.md
  • Update sbt-dotty to 0.5.3
  • Fixing rebalance handling (Rebalance doesn't work reliably fd4s/fs2-kafka#532)
  • make FakeFiber package-private and final
  • provide cancel token for future cancel token
  • Update sbt-mdoc to 2.2.18
  • Update cats-effect-laws to 2.3.3
  • Update fs2-core to 2.5.1
  • Update build.sbt
  • bump cats-effect to RC2
  • Update build.sbt
  • Update build.sbt
  • Update fs2-core to 2.5.2
  • remove master from ci target branches
  • update github workflow
  • update vulcan, scala, discipline-scalatest, cats-testkit-scalatest
  • update github workflow
  • bump fs2 milestone
  • Update fs2-core to 2.5.3
  • Update testcontainers-scala-kafka, ... to 0.39.2
  • Update testcontainers-scala-kafka, ... to 0.39.3
  • Fix Scalafix
  • Revert withCredentials method on AvroSettings and SchemaRegistryClientSettings
  • Create PemKafkaCredentialStore
  • Update sbt to 1.4.9
  • Applied Scalafix rule(s) github:typelevel/cats-effect/v2_4_0?sha=series/2.x
  • Update cats-effect, cats-effect-laws to 2.4.0
  • Update kafka-avro-serializer to 6.1.1
  • Update sbt-ci-release to 1.5.7
  • backport scalafix fix to 1.x branch
  • Update to cats-effect 3.0 and fs2 3.0
  • Update vulcan to 1.5.0
  • Update sbt-mdoc to 2.2.19
  • Update cats-effect, cats-effect-laws to 2.4.1
  • Update sbt-dotty to 0.5.4
  • dependency bumps
  • Update fs2-core to 2.5.4
  • Fix scaladoc
  • More idiomatic syntax for instantiating things via partial application
  • Update merged code for CE3, remove deprecated things
  • Update to Scala 3.0.0-RC2, 2.13.5
  • Revert "Update to Scala 3.0.0-RC2, 2.13.5"
  • Revert "Revert "Update to Scala 3.0.0-RC2, 2.13.5""
  • Update github workflow
  • Update sbt to 1.5.0
  • Updates for sbt 1.5.0
  • MkConsumer
  • Simplify + add tests
  • Update certificates.md
  • Scalafix for new partial application syntax
  • ScalaFix rules for reordering of passthrough params
  • refactor MkConsumer
  • Add MkAdminClient, require bootstrap servers for AdminClientSettings.apply
  • Add MkProducer, make all factories take implicit Mk
  • fix doc
  • Update AdminClientSettings.scala
  • Add missing headers
  • Update doc
  • Add docs
  • Remove unused imports
  • Remove unused context bound
  • deprecate ConsumerSettings#withBlocker
  • Use single thread for KafkaConsumer
  • Add missing MkProducer parameter
  • Stop factory methods compiling without Mk instance
  • Remove unused import
  • Fix compilation in Scala 2.12
  • Use blocker for scheduling commitAsync, remove semaphore from WithConsumer
  • Replace Deferred with Promise in KafkaProducer, remove Dispatcher
  • Decouple settings type of Mk from effect type
  • Replace ConsumerSettings#withBlocker deprecation with comment
  • Allow use of custom blocking context for Consumer and Producer
  • Remove unneeded type parameters
  • Remove moar unneeded type parameters
  • Remove more type parameters, narrow some types
  • Fix variance
  • Add resourceIn/streamIn for KafkaAdminClient
  • Produce on custom blocking context when configured
  • Add dual-effect constructors for KafkaProducerConnection
  • Make type param ordering consistent
  • Fix build
  • Fix scala 3 compilation
  • Update kafka-clients to 2.8.0
  • Update cats-effect, cats-effect-laws to 2.5.0
  • Update sbt-mdoc to 2.2.20
  • Update fs2-core to 2.5.5
  • Update fs2-core to 3.0.2
  • Update sbt to 1.5.1
  • Update cats-effect, cats-effect-laws, ... to 3.0.2
  • Update cats-effect, cats-effect-laws, ... to 3.1.0
  • Fix pem format
  • Fix pem format (backport)
  • Update cats, to 2.6.0, vulcan to 1.6.0, Scala to 3.0.0-RC3
  • Update ci.yml
  • Update discipline-scalatest, cats-testkit-scalatest to 2.1.4
  • Update sbt to 1.5.2
  • Regenerate workflow with sbt-github-actions
  • Update testcontainers-scala-kafka, ... to 0.39.4
  • Update sbt-mima-plugin to 0.9.1
  • Update sbt-mdoc to 2.2.21
  • Update kind-projector to 0.13.0
  • Scala 3 final
  • Update scala-library to 2.13.6
  • Inline the dependency on cats-testkit-scalatest
  • Update ci.yml
  • update to scala 2.13.6
  • Update build.sbt
  • Update kind-projector
  • Update CE version
  • Update vulcan to 1.7.1
  • Update vulcan to 1.7.1
  • Update testcontainers-scala-kafka, ... to 0.39.5
  • Update sbt-mima-plugin to 0.9.2
  • Update scala-library to 2.12.14
  • Regenerate workflow with sbt-github-actions
  • Update sbt-github-actions to 0.12.0
  • Regenerate workflow with sbt-github-actions
  • Update kafka-avro-serializer to 6.2.0
  • Add transactional producer metrics
  • Update sbt to 1.5.4
  • Regenerate workflow with sbt-github-actions
  • Add convinience methods
  • Add scaladoc
  • Fix tests
  • Add testkit module with munit dep
  • Add compatibility fixture
  • Rename file
  • Switch to extension methods to avoid binary compat issues
  • Update error message
  • Reduce constraint to Functor
  • Format
  • extend AnyVal
  • Format
  • Add tests to cover new methods
  • merge series/1.x into series/2.x
  • Update fs2-core to 3.0.6
  • Update sbt-scalafmt to 2.4.3
  • Update scala3-library to 3.0.1
  • Regenerate workflow with sbt-github-actions
  • Update sbt to 1.5.5
  • Update sbt-github-actions to 0.12.0
  • Regenerate workflow with sbt-github-actions
  • Add a minimal readme
  • Reorder sections
  • Update list of developers
  • Remove Scala 3 mima exclusion
  • Remove Mima exclusion for scala 3
  • scalafmt
  • Update build
  • Exclude new module from mima
  • Run scalafmt
  • Update munit
  • Add headers
  • Update sbt-mdoc to 2.2.22
  • Update logback-classic to 1.2.5
  • Update build.sbt
  • Update fs2-core to 3.1.0
  • Update sbt-github-actions to 0.13.0
  • Regenerate workflow with sbt-github-actions
  • Update cats-effect, cats-effect-laws, ... to 3.2.3
  • Add build.sbt instructions re: fs2-kafka-vulcan
  • Syntax for stream of consumer
  • Use consumer stream syntax in tests and docs
  • revert erroneous change
  • revert erroneous change
  • Weaken context bound
  • rename vulcan-testkit to vulcan-testkit-munit
  • Update README.md
  • Add records aliases for stream
  • dependency updates (1.x)
  • Update github workflow
  • merge series/1.x
  • generate workflow
  • Update munit to 0.7.28
  • Update testcontainers-scala-kafka, ... to 0.39.6
  • Final def
  • merge 1.x into 2.x
  • Merge fixes
  • Add docs for munit module
  • Correct var name
  • Update sbt-mdoc to 2.2.23
  • Update munit to 0.7.29
  • Update scala3-library to 3.0.2
  • Regenerate workflow with sbt-github-actions
  • Update kind-projector to 0.13.2
  • Update logback-classic to 1.2.6
  • Add AvroSettings.registerSchema method
  • Update docs
  • Update docs
  • Update docs; fix mima filters
  • Update scala-library to 2.12.15
  • Update kafka-clients to 2.8.1
  • Update cats-effect, cats-effect-laws, ... to 3.2.9
  • Update testcontainers-scala-kafka, ... to 0.39.8
  • Update sbt-ci-release to 1.5.9
  • Update kafka-avro-serializer to 6.2.1
  • Update sbt-mima-plugin to 1.0.1
  • Update sbt-ci-release to 1.5.10
  • Update fs2-core to 3.1.6
  • Update scala3-library to 3.1.0
  • Regenerate workflow with sbt-github-actions
  • Update fs2-core to 2.5.10 in series/1.x
  • Update sbt-ci-release to 1.5.9 in series/1.x
  • Update kafka-clients to 2.8.1 in series/1.x
  • Update scala-library to 2.12.15 in series/1.x
  • Update munit to 0.7.29 in series/1.x
  • Update sbt-mdoc to 2.2.23 in series/1.x
  • Update cats-effect, cats-effect-laws to 2.5.4 in series/1.x
  • Update kind-projector to 0.13.2 in series/1.x
  • Update sbt-mdoc to 2.2.24
  • Update sbt-mdoc to 2.2.24 in series/1.x
  • Add deleteConsumerGroups method
  • rerun build
  • Ignore mima, abstract List
  • rerun build
  • Update sbt-unidoc to 0.5.0
  • Update sbt-unidoc to 0.5.0 in series/1.x
  • Update scala-library to 2.13.7
  • Update scala-library to 2.13.7 in series/1.x
  • Update testcontainers-scala-kafka, ... to 0.39.12
  • Update testcontainers-scala-kafka, ... to 0.39.12 in series/1.x
  • Update code to use modern cats import
  • Update kafka-avro-serializer to 6.2.2
  • Update kafka-avro-serializer to 6.2.2 in series/1.x
  • Update sbt to 1.5.6
  • Update sbt to 1.5.6 in series/1.x
  • Update logback-classic to 1.2.8
  • Update logback-classic to 1.2.8 in series/1.x
  • Update sbt to 1.5.7
  • Update sbt to 1.5.7 in series/1.x
  • Update logback-classic to 1.2.9
  • Update logback-classic to 1.2.9 in series/1.x
  • Update sbt to 1.5.8
  • Update sbt to 1.5.8 in series/1.x
  • Update logback-classic to 1.2.10
  • Update logback-classic to 1.2.10 in series/1.x
  • Update sbt-scalafmt to 2.4.6
  • Update sbt-scalafmt to 2.4.6 in series/1.x
  • Update fs2-core to 3.2.4
  • Update sbt to 1.6.1
  • Update sbt to 1.6.1 in series/1.x
  • Update cats-effect, cats-effect-laws, ... to 3.3.3
  • Update kafka-avro-serializer to 7.0.1
  • Update kafka-avro-serializer to 7.0.1 in series/1.x
  • fix build.sbt
  • Fixes
  • githubworkflowgenerate
  • Revert "Update kafka-avro-serializer to 7.0.1 in series/1.x"
  • Revert "Update kafka-avro-serializer to 7.0.1"
  • Happy new year 2022
  • Update headers for scala 2.12
  • Update copyright headers
  • Fix serde tests for CE3.3
  • Fix build.sbt
  • Revise doc
  • Update headers
  • Update headers
  • Add missing import to testkit doc
  • Update mima
  • Update cats-effect, cats-effect-laws, ... to 3.3.4
  • Update scala-library to 2.13.8
  • Update scala-library to 2.13.8 in series/1.x
  • Update README.md
  • Update README.md
  • Add support for using CooperativeStickyAssignor with KafkaConsumer
  • Update documentation for partitionsMapStream
  • Update testcontainers-scala-kafka, ... to 0.40.0 in series/1.x
  • Update cats-effect, cats-effect-laws, ... to 3.3.5
  • Update sbt to 1.6.2
  • Update sbt to 1.6.2 in series/1.x
  • Update scala3-library to 3.1.1
  • Regenerate workflow with sbt-github-actions
  • Switch partitionsMapStream to use per-assignment finisher
  • Update sbt-header to 5.6.5
  • Update sbt-header to 5.6.5 in series/1.x
  • Update sbt-buildinfo to 0.11.0
  • Update sbt-buildinfo to 0.11.0 in series/1.x
  • Update fs2-core to 3.2.5
  • Improve scala-steward config for 1.x series
  • Slighlty improve docs for stream methods
  • Publish certs docs
  • Update cats-effect-laws, ... to 3.3.6
  • Allow transaction without upstream offsets
  • Source compat fix
  • Add tests for producing without offsets
  • Add scaladoc
  • Update transactional producer docs
  • Add attempt method to RecordDeserializer
  • Threadsafe transactions
  • Update vulcan version to 1.8.0
  • Update gitignore
  • Have KafkaProducerConnection extend KafkaProducer[F, Array[Byte], Array[Byte]]
  • Rework producerconnection
  • KafkaProducer delegates to KafkaProducerConnection
  • Remove deserialization from KafkaConsumerActor
  • Simplification
  • remove commented
  • Don't pass offsetCommit around everywhere
  • Move consumer group id back to kafka consumer
  • Revert formatting changes
  • Add mima exclusion
  • Add mima exclusion
  • scalafmt
  • Semaphore-like subscribe
  • Remove unused import
  • Use permit for subscribe and unsubscribe
  • Use permit for assign
  • Use semaphore for assignment
  • fixes
  • Use IOApp.Simple in docs
  • withParalellism default 100 -> 10000 in docs
  • Update logback-classic to 1.2.11
  • Update cats-effect-laws, ... to 3.3.7
  • Add ProducerSettings.nothing
  • Add ProducerSettings.unit, withDeserializers
  • Fixes
  • Method rename
  • Put missing apply method back
  • Add mima exclusions
  • Move derived consumer methods to traits
  • Use permit for fetch
  • KafkaOffsets.committed methods added
  • Fix deadlock
  • asInstanceOf
  • Fix deadlock
  • Refactoring
  • Remove fiber leak
  • Remove obsolete comment
  • refactor
  • Rework permits
  • mimaBinaryIssueFilters += ProblemFilters.excludeReversedMissingMethodProblem
  • Update testcontainers version, set image name and version explicitly
  • Up-to-date ACL authorizer
  • Use native Scala 3 testcontainers
  • KafkaOffsets format fixed
  • Remove unneeded braces
  • KafkaOffsetsV2
  • Use foralltestcontainer
  • Run producer timeout test with separate container
  • Exactly-once consumption is not guraranteed
  • Update sbt-gha, add JDK 17 to pipeline
  • Update testcontainers-scala-kafka, ... to 0.40.4
  • Update sbt-mdoc to 2.3.2
  • Update cats-effect-laws, ... to 3.3.9
  • header for KafkaOffsetsV2
  • Fix auto-registration of union types
  • Fix scala 2.12 compilation
  • Scala 3.1.2-RC3
  • Update githubworkflow
  • Scala 3 bug workaround
  • Revert workflow changes
  • Add header
  • Update vulcan to 1.8.3
  • Update sbt-mima-plugin to 1.1.0
  • Update scala3-library to 3.1.2
  • Regenerate workflow with sbt-github-actions
  • Update cats-effect-laws, ... to 3.3.11
  • Update sbt-header to 5.7.0
  • Update testcontainers-scala-kafka, ... to 0.40.7
  • Revert "Merge pull request Move deserialization from KafkaConsumerActor to KafkaConsumer fd4s/fs2-kafka#902 from fd4s/untyped-actor"
  • Add compatiblity assertions with clues

keirlawson and others added 30 commits October 21, 2021 08:57
…ack-classic-1.2.8

Update logback-classic to 1.2.8 in series/1.x
bplommer and others added 29 commits March 31, 2022 17:16
…scala-kafka-0.40.4

Update testcontainers-scala-kafka, ... to 0.40.4
…s-3.3.9

Update cats-effect-laws, ... to 3.3.9
Fix auto-registration of Avro union (etc) types
Update sbt-gha, add JDK 17 to pipeline
…s-3.3.11

Update cats-effect-laws, ... to 3.3.11
This reverts commit 19f5210, reversing
changes made to 5aa90d7.
…scala-kafka-0.40.7

Update testcontainers-scala-kafka, ... to 0.40.7
@keirlawson keirlawson closed this Jun 6, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

9 participants