thomhurst

thomhurst/Dekaf

Taking the Java out of Kafka

9 stars 1 forks 9 watchers C# MIT License
View on GitHub
17 Open Issues Need Help Last updated: Mar 8, 2026

Open Issues Need Help

View All on GitHub
perf(consumer): EstimatePendingFetchBytes boxes an interface enumerator twice per partition-fetch about 1 month ago
good first issue performance P3 consumer in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
perf(protocol): WriteString/WriteCompactString span overloads still double-pass UTF-8 about 1 month ago
good first issue performance P3 protocol in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
fix(security): OAuthBearerTokenProvider default HttpClient never re-resolves DNS (no PooledConnectionLifetime) about 1 month ago
bug good first issue P3 in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
fix(consumer): ConsumerOptions.MaxPollRecords is accepted but never read about 1 month ago
bug good first issue P3 consumer in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
fix(schemaregistry): Protobuf serializer ContinueWith(t => t.Result) surfaces AggregateException instead of the real error about 1 month ago
bug good first issue P3 in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
KIP-1118: Deadlock protection for FlushAsync in delivery callbacks about 1 month ago
enhancement good first issue P2 producer kafka-4.1 in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Wire TopicId through ForgottenTopic for Fetch v13+ sessions about 1 month ago
bug good first issue in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
perf(json): Utf8JsonWriter allocated per message in JsonSerializer<T> about 1 month ago
good first issue performance P2 in-progress
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
perf: unnecessary array clearing in BatchArena pool return 5 months ago

AI Summary: The `BatchArena.ReturnToPool` method unnecessarily clears large byte arrays (1MB+) when returning them to the shared `ArrayPool`, consuming 0.10% exclusive CPU. This clearing is redundant because the data is not sensitive and the buffer will be fully overwritten on its next use. The proposed fix is a one-line change to disable array clearing.

Complexity: 1/5
good first issue performance P3
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Clarify consumer thread-safety documentation 6 months ago
documentation good first issue P3
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Protobuf varint encoding is duplicated across calculate and write methods 6 months ago
bug good first issue P3
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Add DI convenience extensions for serializer registration 6 months ago
enhancement good first issue api P3
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
ParseAndSliceResponse returns null without diagnostic context 6 months ago
bug good first issue P1
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Add Brotli compression codec 6 months ago
enhancement help wanted P3
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Add IPartitionAssignmentStrategy for custom client-side partition assignment 6 months ago
enhancement help wanted
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Performance: byte[] allocation in SendSaslMessageAsync 6 months ago

AI Summary: The `SendSaslMessageAsync` method in `KafkaConnection.cs` allocates three `byte[]` arrays during SASL message exchanges, which occur only during connection authentication. To reduce these avoidable memory allocations, the issue proposes using `ArrayPool<byte>` to rent and return temporary buffers.

Complexity: 2/5
enhancement good first issue
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#
Performance: SerializationContext allocation on every serialization 6 months ago
enhancement good first issue
thomhurst/Dekaf
9

Taking the Java out of Kafka

C#