We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1818971 commit 3964950Copy full SHA for 3964950
modules/kafka/kafka.go
@@ -52,7 +52,7 @@ func RunContainer(ctx context.Context, opts ...testcontainers.ContainerCustomize
52
"KAFKA_OFFSETS_TOPIC_NUM_PARTITIONS": "1",
53
"KAFKA_TRANSACTION_STATE_LOG_REPLICATION_FACTOR": "1",
54
"KAFKA_TRANSACTION_STATE_LOG_MIN_ISR": "1",
55
- "KAFKA_LOG_FLUSH_INTERVAL_MESSAGES": fmt.Sprintf("%d", math.MaxInt64),
+ "KAFKA_LOG_FLUSH_INTERVAL_MESSAGES": fmt.Sprintf("%d", math.MaxInt),
56
"KAFKA_GROUP_INITIAL_REBALANCE_DELAY_MS": "0",
57
"KAFKA_NODE_ID": "1",
58
"KAFKA_PROCESS_ROLES": "broker,controller",
0 commit comments