fix example, build

Author: rekby

examples/topic/topicreader/topicreader_handler.go

@@ -47,7 +47,8 @@ func (h *TopicEventsHandler) OnReadMessages(
 	for _, mess := range event.Batch.Messages {
 		log.Printf("Receive message: %v/%v/%v", mess.Topic(), mess.PartitionID(), mess.SeqNo)
 	}
-	_ = h.listener.Commit(ctx, event.Batch)
+
+	processBatch(ctx, event.Batch)
 
 	return nil
 }

internal/topic/topiclistenerinternal/stream_listener.go

@@ -20,7 +20,7 @@ import (
 )
 
 type streamListener struct {
-	cfg StreamListenerConfig
+	cfg *StreamListenerConfig
 
 	stream      rawtopicreader.TopicReaderStreamInterface
 	streamClose context.CancelCauseFunc
@@ -41,7 +41,7 @@ func newStreamListener(
 	connectionCtx context.Context,
 	client TopicClient,
 	eventListener EventHandler,
-	config StreamListenerConfig,
+	config *StreamListenerConfig,
 	sessionIDCounter *atomic.Int64,
 ) (*streamListener, error) {
 	res := &streamListener{