Skip to content

Commit

Permalink
Merge branch 'main' into container-exec-options
Browse files Browse the repository at this point in the history
* main:
  fix(modules.kafka): Switch to MaxInt for 32-bit support (testcontainers#1923)
  docs: fix code snippet for image substitution (testcontainers#1918)
  Add database driver note to SQL Wait strategy docs (testcontainers#1916)
  • Loading branch information
mdelapenya committed Nov 17, 2023
2 parents f600e9e + 68d5f89 commit 9d92e69
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 2 deletions.
2 changes: 1 addition & 1 deletion docs/features/image_name_substitution.md
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,6 @@ An image name substitutor converts a Docker image name, as may be specified in c
_Testcontainers for Go_ exposes an interface to perform this operations: `ImageSubstitutor`, and a No-operation implementation to be used as reference for custom implementations:

<!--codeinclude-->
[Image Substitutor Interface](../../generic.go) inside_block:imageSubstitutor
[Image Substitutor Interface](../../options.go) inside_block:imageSubstitutor
[Noop Image Substitutor](../../container_test.go) inside_block:noopImageSubstitutor
<!--/codeinclude-->
2 changes: 2 additions & 0 deletions docs/features/wait/sql.md
Original file line number Diff line number Diff line change
Expand Up @@ -20,3 +20,5 @@ req := ContainerRequest{
WithQuery("SELECT 10"),
}
```

Note: You'll also need to import the appropriate [database driver](https://github.com/golang/go/wiki/SQLDrivers) in your test code such that Testcontainers can pick it up when connecting to the database.
2 changes: 1 addition & 1 deletion modules/kafka/kafka.go
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomize
"KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS": "1",
"KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR": "1",
"KAFKA_TRANSACTION_STATE_LOG_MIN_ISR": "1",
"KAFKA_LOG_FLUSH_INTERVAL_MESSAGES": fmt.Sprintf("%d", math.MaxInt64),
"KAFKA_LOG_FLUSH_INTERVAL_MESSAGES": fmt.Sprintf("%d", math.MaxInt),
"KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS": "0",
"KAFKA_NODE_ID": "1",
"KAFKA_PROCESS_ROLES": "broker,controller",
Expand Down

0 comments on commit 9d92e69

Please sign in to comment.