fixed topic parameter value assignment

Signed-off-by: axfor <aixiaoxiang2009@hotmail.com>
axfor · Jul 22, 2023 · 77acc07 · 77acc07
1 parent 95d97e0
commit 77acc07
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/cmd/ingester/app/builder/builder.go b/cmd/ingester/app/builder/builder.go
@@ -65,11 +65,13 @@ func CreateConsumer(logger *zap.Logger, metricsFactory metrics.Factory, spanWrit
 
 	factoryParams := consumer.ProcessorFactoryParams{
 		Parallelism:    options.Parallelism,
+		Topic:          options.Topic,
 		SaramaConsumer: saramaConsumer,
 		BaseProcessor:  spanProcessor,
 		Logger:         logger,
 		Factory:        metricsFactory,
 	}
+
 	processorFactory, err := consumer.NewProcessorFactory(factoryParams)
 	if err != nil {
 		return nil, err

diff --git a/cmd/ingester/app/consumer/consumer_test.go b/cmd/ingester/app/consumer/consumer_test.go
@@ -151,8 +151,8 @@ func TestGroupConsumer(t *testing.T) {
 
 	logger, logBuf := testutils.NewLogger()
 	factoryParams := ProcessorFactoryParams{
-		Topic:          topic,
 		Parallelism:    1,
+		Topic:          topic,
 		SaramaConsumer: saramaConsumer,
 		BaseProcessor:  spanProcessor,
 		Logger:         logger,
@@ -289,8 +289,8 @@ func TestGroupConsumerWithDeadlockDetector(t *testing.T) {
 
 	logger, logBuf := testutils.NewLogger()
 	factoryParams := ProcessorFactoryParams{
-		Topic:          topic,
 		Parallelism:    1,
+		Topic:          topic,
 		SaramaConsumer: saramaConsumer,
 		BaseProcessor:  spanProcessor,
 		Logger:         logger,

diff --git a/cmd/ingester/app/consumer/processor_factory_test.go b/cmd/ingester/app/consumer/processor_factory_test.go
@@ -126,8 +126,8 @@ func Test_New(t *testing.T) {
 	processor.On("Close").Return(nil)
 
 	factoryParams := ProcessorFactoryParams{
-		Topic:         "fake_msg_test",
 		Parallelism:   1,
+		Topic:         "fake_msg_test",
 		BaseProcessor: processor,
 		Logger:        logger,
 		Factory:       metrics.NullFactory,