Merge pull request redpanda-data#2734 from redpanda-data/limit-cloud-…

…community-builds

Limit cloud and community build artifacts

.goreleaser.yml

@@ -33,14 +33,8 @@ builds:
   - id: connect-cloud
     main: cmd/redpanda-connect-cloud/main.go
     binary: redpanda-connect
-    goos: [ windows, darwin, linux, freebsd, openbsd ]
-    goarch: [ amd64, arm, arm64 ]
-    goarm: [ 6, 7 ]
-    ignore:
-      - goos: windows
-        goarch: arm
-      - goos: darwin
-        goarch: arm
+    goos: [ darwin, linux ]
+    goarch: [ amd64, arm64 ]
     env:
       - CGO_ENABLED=0
     ldflags: >
@@ -52,14 +46,8 @@ builds:
   - id: connect-community
     main: cmd/redpanda-connect-community/main.go
     binary: redpanda-connect
-    goos: [ windows, darwin, linux, freebsd, openbsd ]
-    goarch: [ amd64, arm, arm64 ]
-    goarm: [ 6, 7 ]
-    ignore:
-      - goos: windows
-        goarch: arm
-      - goos: darwin
-        goarch: arm
+    goos: [ darwin, linux ]
+    goarch: [ amd64, arm64 ]
     env:
       - CGO_ENABLED=0
     ldflags: >

CHANGELOG.md

@@ -3,6 +3,12 @@ Changelog
 
 All notable changes to this project will be documented in this file.
 
+## 4.32.1 - 2024-07-24
+
+### Changed
+
+- The number of release build artifacts for the `community` and `cloud` flavours have been reduced due to Github Action Runner disk space limitations.
+
 ## 4.32.0 - 2024-07-24
 
 ### Added

internal/impl/kafka/enterprise/status_updates.go

@@ -60,8 +60,7 @@ func (l *TopicLogger) TriggerEventStopped(err error) {
 }
 
 func (l *TopicLogger) sendStatusEvent(e *protoconnect.StatusEvent) {
-	tmpO := l.o.Load()
-	if tmpO == nil || l.statusTopic == "" {
+	if l.statusTopic == "" {
 		return
 	}
 
@@ -75,6 +74,10 @@ func (l *TopicLogger) sendStatusEvent(e *protoconnect.StatusEvent) {
 	msg.SetBytes(data)
 	msg.MetaSetMut(topicMetaKey, l.statusTopic)
 
+	tmpO := l.o.Load()
+	if tmpO == nil {
+		return
+	}
 	_ = tmpO.WriteBatchNonBlocking(service.MessageBatch{msg}, func(ctx context.Context, err error) error {
 		return nil // TODO: Log nacks
 	}) // TODO: Log errors (occasionally)

internal/impl/kafka/enterprise/topic_logger.go

@@ -190,8 +190,7 @@ func (l *TopicLogger) Enabled(ctx context.Context, atLevel slog.Level) bool {
 
 // Handle invokes the logger for the input record.
 func (l *TopicLogger) Handle(ctx context.Context, r slog.Record) error {
-	tmpO := l.o.Load()
-	if tmpO == nil || l.logsTopic == "" {
+	if l.logsTopic == "" {
 		return nil
 	}
 
@@ -219,6 +218,10 @@ func (l *TopicLogger) Handle(ctx context.Context, r slog.Record) error {
 	msg.SetStructured(v)
 	msg.MetaSetMut(topicMetaKey, l.logsTopic)
 
+	tmpO := l.o.Load()
+	if tmpO == nil {
+		return nil
+	}
 	_ = tmpO.WriteBatchNonBlocking(service.MessageBatch{msg}, func(ctx context.Context, err error) error {
 		return nil // TODO: Log nacks
 	}) // TODO: Log errors (occasionally)
@@ -246,6 +249,7 @@ func (l *TopicLogger) Close(ctx context.Context) error {
 
 	o := l.o.Load()
 	if o != nil {
+		l.o.Store(nil)
 		if err := o.Close(ctx); err != nil {
 			return err
 		}