mirror of https://github.com/certusone/dc4bc.git
Merge branch 'master' into feat/storage-tendermint
This commit is contained in:
commit
e54878e182
|
@ -67,7 +67,6 @@ func TestKafkaStorage_SendBatch(t *testing.T) {
|
||||||
N := 10
|
N := 10
|
||||||
var offset uint64 = 5
|
var offset uint64 = 5
|
||||||
|
|
||||||
req := require.New(t)
|
|
||||||
producerCreds := &KafkaAuthCredentials{
|
producerCreds := &KafkaAuthCredentials{
|
||||||
Username: "producer",
|
Username: "producer",
|
||||||
Password: "producerpass",
|
Password: "producerpass",
|
||||||
|
@ -82,6 +81,7 @@ func TestKafkaStorage_SendBatch(t *testing.T) {
|
||||||
t.Fatal(err.Error())
|
t.Fatal(err.Error())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
req := require.New(t)
|
||||||
stg, err := NewKafkaStorage(context.Background(), "localhost:9093", "test", tlsConfig, producerCreds, consumerCreds)
|
stg, err := NewKafkaStorage(context.Background(), "localhost:9093", "test", tlsConfig, producerCreds, consumerCreds)
|
||||||
req.NoError(err)
|
req.NoError(err)
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue