Skip to content

Conversation

@Tang8330
Copy link
Contributor

@Tang8330 Tang8330 commented Oct 14, 2025

Using our fork as we have this merged into our fork: segmentio/kafka-go#1365

We need this for KRaft-based Kafka clusters.


Note

Switches to the artie-labs/kafka-go fork via replace and sets a 30s KeepAlive on the Kafka Dialer.

  • Dependencies:
    • Replace github.com/segmentio/kafka-go with fork github.com/artie-labs/kafka-go in go.mod (via replace), updating go.sum accordingly.
  • Kafka connection:
    • Set KeepAlive: 30 * time.Second on kafka.Dialer in lib/kafkalib/connection.go.

Written by Cursor Bugbot for commit 2acab5a. This will update automatically on new commits. Configure here.

@Tang8330 Tang8330 marked this pull request as ready for review October 14, 2025 21:30
@Tang8330 Tang8330 requested a review from a team as a code owner October 14, 2025 21:30
@Tang8330
Copy link
Contributor Author

@williamhaw Gonna close

@Tang8330 Tang8330 closed this Oct 28, 2025
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

4 participants