feat: rename persistent with interval (#359)
Closes #358
diff --git a/internal/client.go b/internal/client.go
index fec61fd..e566797 100644
--- a/internal/client.go
+++ b/internal/client.go
@@ -48,7 +48,7 @@
_HeartbeatBrokerInterval = 30 * time.Second
// Offset persistent interval for consumer
- _PersistOffset = 5 * time.Second
+ _PersistOffsetInterval = 5 * time.Second
// Rebalance interval
_RebalanceInterval = 20 * time.Second
@@ -320,7 +320,7 @@
// schedule persist offset
go func() {
- ticker := time.NewTicker(_PersistOffset)
+ ticker := time.NewTicker(_PersistOffsetInterval)
defer ticker.Stop()
for {
select {
