Jose Boretto issues

Repositories
Issues
Comments

Results 2 issues of


                                            Jose Boretto

KafkaConsumer - get the latest N messages

``` import json import time from kafka import KafkaConsumer, KafkaProducer, TopicPartition def get_end_offsets(consumer, topic) -> dict: partitions_for_topic = consumer.partitions_for_topic(topic) if partitions_for_topic: partitions = [] for partition in consumer.partitions_for_topic(topic): partitions.append(TopicPartition(topic, partition))...

Generate a struct to assert Calls

# Problem When you need to assert the call, you have to copy/duplicate the "Calls" struct. # Example ```go // When s.GetPerson(ctx, "1") // Then actual := personStore.GetCalls() expected :=...