Kafka

Code generated by counterfeiter.

GetRealOffset get offset for newest or oldest.

NewMessageHandlerBatchMetrics is a MessageHandler adapter that create Prometheus metrics for started, completed and failed.

NewMessageHandlerBatchTxMetrics is a MessageHandler adapter that create Prometheus metrics for started, completed and failed.

NewMessageHandlerMetrics is a MessageHandler adapter that create Prometheus metrics for started, completed and failed.

NewMessageHandlerTxMetrics is a MessageHandler adapter that create Prometheus metrics for started, completed and failed.

NewOffsetTriggerMessageHandler returns message handler that call the given trigger if all offset are reached.

OffsetFromBytes returns the offset for the given bytes.

ParseOffset from a string.

ParsePartition from a string.

PartitionFromBytes returns the partition for the given bytes.

counterfeiter:generate -o mocks/kafka-highwatermark-provider.go --fake-name KafkaHighwaterMarkProvider .

counterfeiter:generate -o mocks/kafka-json-sender.go --fake-name KafkaJsonSender .

counterfeiter:generate -o mocks/kafka-message-handler.go --fake-name KafkaMessageHandler .

counterfeiter:generate -o mocks/kafka-message-handler-batch.go --fake-name KafkaMessageHandlerBatch .

counterfeiter:generate -o mocks/kafka-message-handler-batch-tx.go --fake-name KafkaMessageHandlerBatchTx .

counterfeiter:generate -o mocks/kafka-message-handler-tx.go --fake-name KafkaMessageHandlerTx .

counterfeiter:generate -o mocks/kafka-metrics.go --fake-name KafkaMetrics .

counterfeiter:generate -o mocks/kafka-offset-store.go --fake-name KafkaOffsetStore .

counterfeiter:generate -o mocks/kafka-sarama-client.go --fake-name KafkaSaramaClient .

counterfeiter:generate -o mocks/kafka-sarama-sync-producer.go --fake-name KafkaSaramaSyncProducer .

counterfeiter:generate -o mocks/kafka-sync-producer.go --fake-name KafkaSyncProducer .

MessageHandlerFunc allow use a function as MessageHandler.

MessageHandlerTxFunc allow use a function as MessageHandler.

Offset in the Kafka topic.

Partition in Kafka.