Gallardot 294dd75354 feat: kafka subpub and bindings support compression (#3676) ... Signed-off-by: Gallardot <gallardot@apache.org> Co-authored-by: Josh van Leeuwen <me@joshvanl.dev> Co-authored-by: Yaron Schneider <schneider.yaron@live.com>		2025-05-16 10:45:37 -07:00
..
mocks	PubSub Kafka: Respect Subscribe context (#3363)	2024-02-28 10:13:06 -08:00
auth.go	feat(kafka): iam roles anywhere + assume role auth profiles (#3606)	2024-11-27 14:48:18 -08:00
auth_test.go	Switch to Go 1.21, Updates linter, updates workflows, adds sarama 1.42.1 (#3251)	2023-11-28 18:13:09 -08:00
clients.go	feat(kafka): iam roles anywhere + assume role auth profiles (#3606)	2024-11-27 14:48:18 -08:00
consumer.go	Kafka Pubsub fixes: Avro serialization caching and retries (#3610)	2024-11-26 22:02:19 +00:00
kafka.go	feat: kafka subpub and bindings support compression (#3676)	2025-05-16 10:45:37 -07:00
kafka_test.go	Update go -> 1.24.1 & golangci-lint -> 1.64.6 (#3699)	2025-03-12 13:50:32 -07:00
metadata.go	feat: kafka subpub and bindings support compression (#3676)	2025-05-16 10:45:37 -07:00
metadata_test.go	feat: kafka subpub and bindings support compression (#3676)	2025-05-16 10:45:37 -07:00
producer.go	feat(kafka): iam roles anywhere + assume role auth profiles (#3606)	2024-11-27 14:48:18 -08:00
producer_test.go	Update go -> 1.24.1 & golangci-lint -> 1.64.6 (#3699)	2025-03-12 13:50:32 -07:00
sarama_log_bridge.go	Rename folder "internal" to "common" (#3225)	2023-11-14 11:36:38 -08:00
sasl_oauthbearer.go	Merge 1.14 into master (#3579)	2024-10-24 16:52:48 -07:00
scram_client.go	Rename folder "internal" to "common" (#3225)	2023-11-14 11:36:38 -08:00
subscriber.go	feat(kafka): iam roles anywhere + assume role auth profiles (#3606)	2024-11-27 14:48:18 -08:00
subscriber_test.go	Update go -> 1.24.1 & golangci-lint -> 1.64.6 (#3699)	2025-03-12 13:50:32 -07:00
utils.go	feat: kafka subpub and bindings support compression (#3676)	2025-05-16 10:45:37 -07:00