1 write to consumer
Aspire.Confluent.Kafka (1)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (1)
18this.consumer = consumer;
38 references to consumer
Aspire.Confluent.Kafka (38)
src\Vendoring\OpenTelemetry.Instrumentation.ConfluentKafka\InstrumentedConsumer.cs (38)
22public Handle Handle => this.consumer.Handle; 24public string Name => this.consumer.Name; 26public string MemberId => this.consumer.MemberId; 28public List<TopicPartition> Assignment => this.consumer.Assignment; 30public List<string> Subscription => this.consumer.Subscription; 32public IConsumerGroupMetadata ConsumerGroupMetadata => this.consumer.ConsumerGroupMetadata; 38this.consumer.Dispose(); 43return this.consumer.AddBrokers(brokers); 48this.consumer.SetSaslCredentials(username, password); 59result = this.consumer.Consume(millisecondsTimeout); 86result = this.consumer.Consume(cancellationToken); 113result = this.consumer.Consume(timeout); 134this.consumer.Subscribe(topics); 139this.consumer.Subscribe(topic); 144this.consumer.Unsubscribe(); 149this.consumer.Assign(partition); 154this.consumer.Assign(partition); 159this.consumer.Assign(partitions); 164this.consumer.Assign(partitions); 169this.consumer.IncrementalAssign(partitions); 174this.consumer.IncrementalAssign(partitions); 179this.consumer.IncrementalUnassign(partitions); 184this.consumer.Unassign(); 189this.consumer.StoreOffset(result); 194this.consumer.StoreOffset(offset); 199return this.consumer.Commit(); 204this.consumer.Commit(offsets); 209this.consumer.Commit(result); 214this.consumer.Seek(tpo); 219this.consumer.Pause(partitions); 224this.consumer.Resume(partitions); 229return this.consumer.Committed(timeout); 234return this.consumer.Committed(partitions, timeout); 239return this.consumer.Position(partition); 244return this.consumer.OffsetsForTimes(timestampsToSearch, timeout); 249return this.consumer.GetWatermarkOffsets(topicPartition); 254return this.consumer.QueryWatermarkOffsets(topicPartition, timeout); 259this.consumer.Close();