Skip to content

Commit 85f4773

Browse files
author
Christian Perez-Llamas
committed
Updated ScalaDocs and README
1 parent fc4874a commit 85f4773

File tree

2 files changed

+6
-4
lines changed

2 files changed

+6
-4
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ The `EmbeddedKafka` trait provides also some utility methods to interact with th
8181
8282
def consumeFirstMessageFrom(topic: String): String
8383

84-
def createCustomTopic(topic: String, topicConfig: Map[String,String]): Unit
84+
def createCustomTopic(topic: String, topicConfig: Map[String,String], partitions: Int, replicationFactor: Int): Unit
8585
8686
## Custom producers
8787

src/main/scala/net/manub/embeddedkafka/EmbeddedKafka.scala

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -242,9 +242,11 @@ sealed trait EmbeddedKafkaSupport {
242242
/**
243243
* Creates a topic with a custom configuration
244244
*
245-
* @param topic the topic name
246-
* @param topicConfig per topic configuration [[Map]]
247-
* @param config an implicit [[EmbeddedKafkaConfig]]
245+
* @param topic the topic name
246+
* @param topicConfig per topic configuration [[Map]]
247+
* @param partitions number of partitions [[Int]]
248+
* @param replicationFactor replication factor [[Int]]
249+
* @param config an implicit [[EmbeddedKafkaConfig]]
248250
*/
249251
def createCustomTopic(topic: String, topicConfig: Map[String,String] = Map.empty,
250252
partitions: Int = 1, replicationFactor: Int = 1)(implicit config: EmbeddedKafkaConfig): Unit = {

0 commit comments

Comments
 (0)