mguenther/kafka-junit

Issues

• Upgrade to Kafka 3.7

  #103 opened 4 months ago by philipp94831
  0

• Kafka 3.6.0

  #101 opened a year ago by KliminV
  2

• Document using Kafka for JUnit with Spring Kafka

  #82 opened 2 years ago by mguenther
  6

• CVE-2020-8908 in Transitive Dependency

  #99 opened a year ago by jburgess
  3

• port conflict with random zookeeper ports

  #98 opened a year ago by dlipofsky
  4

• Apache Kafka 3.5.x Support?

  #97 opened a year ago by locomark
  2

• Copy-Paste Sample Code in Docs Not Working

  #96 opened a year ago by matthewparks-rts
  6

• Support for sending a message to a topic that has compression enabled

  #95 opened a year ago by krumft
  3

• Cannot connect to embedded Kafka brokers via TCP

  #94 opened a year ago by krumft
  1

• question: is it possible to define random ports for the cluster

  #91 opened 2 years ago by cstmgl
  1

• lost messages after upgrade from 2.8 to 3.2

  #79 opened 2 years ago by dlipofsky
  9

• Upgrade to Kafka 3.4

  #93 opened 2 years ago by philipp94831
  5

• can we define an embedded connect cluster that connects to an external kakfa cluster?

  #92 opened 2 years ago by cstmgl
  1

• Upgrade to Kafka 3.3

  #90 opened 2 years ago by philipp94831
  4

• Update the README.md and documentation to only show latest versions from a release line

  #89 opened 2 years ago by mguenther
  0

• Typo in sample test case shouldWaitForRecordsToBePublished form readme

  #72 opened 2 years ago by vaibhav-b
  2

• Fix deprecated API usage in class `DefaultRecordConsumer`

  #75 opened 2 years ago by mguenther
  0

• question regarding multi thread on update from kafka 2.8 to 3.0

  #70 opened 2 years ago by cstmgl
  15

• Embedded Kafka not starting when SSL is enabled

  #85 opened 2 years ago by aminders485
  6

• Remove deprecated methods from the public API of Kafka for JUnit

  #74 opened 2 years ago by mguenther
  4

• Remove usage of yet unsupported Java >8 language features

  #86 opened 2 years ago by mguenther
  3

• Enforce `log.cleanup.policy=compact` in the presence of an embedded Kafka Connect deployment

  #87 opened 2 years ago by mguenther
  6

• Fix deprecated API usage in class `EmbeddedConnect`

  #77 opened 2 years ago by mguenther
  4

• Fix deprecated API usage in class `DefaultTopicManager`

  #76 opened 2 years ago by mguenther
  4

• kafka-junit library not useful with KafkaListener interface and Kafkatemplate class ?

  #73 opened 2 years ago by vaibhav-b
  3

• Fix deprecated API usage in class `ExternalKafkaClusterTest`

  #78 opened 2 years ago by mguenther
  4

• Increase Kafka dependencies to 3.2.3

  #80 opened 2 years ago by mguenther
  1

• Scala 2.12 support

  #68 opened 2 years ago by misinspire
  3

• Support for testing a Kafka Connect connector

  #71 opened 2 years ago by rjrudin
  2

• Using connectors, how do I know what triggers my connector code (not a bug)

  #67 opened 2 years ago by cstmgl
  2

• KafkaConfig$.MODULE$.PortProp() does no longer exist in 3.2.0

  #66 opened 2 years ago by stinnux
  3

• Increase Apache Kafka dependency to 3.2.0

  #64 opened 3 years ago by BenjaminBuick
  1

• Risks of Running Version Higher Than Actual Cluster

  #63 opened 3 years ago by ajameson-hbo
  2

• Increase Apache Kafka dependency to 3.1.0

  #62 opened 3 years ago by mguenther
  1

• jackson-databind 2.10 has been closed

  #59 opened 3 years ago by julianladisch
  2

• Increase Apache Kafka dependency to 3.0.0

  #61 opened 3 years ago by mguenther
  1

• Upgrade a couple of dependencies

  #60 opened 3 years ago by mguenther
  1

• java.lang.NoSuchFieldError: DEFAULT_SOCKET_CONNECTION_SETUP_TIMEOUT_MS

  #58 opened 3 years ago by twoi
  2

• Increase Apache Kafka dependency to 2.8.0

  #57 opened 4 years ago by mguenther
  1

• Can we assign static port for broker instead of randomly assigned to EmbeddedKafkaCluster?

  #56 opened 4 years ago by erohini
  1

• Increase Apache Kafka dependency to 2.7.0

  #55 opened 4 years ago by mguenther
  1

• Migrate JUnit 4 tests to JUnit Jupiter tests

  #54 opened 4 years ago by mguenther
  1

• Using EmbeddedKafkaCluster with KafkaConsumer

  #53 opened 4 years ago by mustafakirkpinar
  1

• Simplify the API for RecordConsumer and RecordProducer

  #52 opened 4 years ago by mguenther
  2

• Increase JUnit dependency to 4.13.1

  #51 opened 4 years ago by mguenther
  0

• Increase Kafka dependency to 2.6.0

  #50 opened 4 years ago by mguenther
  1

• Broker address changes after disconnecting and reconnecting brokers in an embedded kafka cluster

  #48 opened 4 years ago by sunnylohani
  6

• Increase Apache Kafka dependency to 2.5.x

  #47 opened 4 years ago by mguenther
  1

• NoClassDefFoundError on EmbeddedKafkaCluster initialisation

  #45 opened 5 years ago by DanielAmorim
  1

• java.lang.NoClassDefFoundError: org/apache/kafka/server/authorizer/Authorizer

  #44 opened 5 years ago by winaterion
  1