Skip to content

Instantly share code, notes, and snippets.

@slfritchie

slfritchie/gist:6050408a3363ad301c1214921634f601 Secret

Created March 1, 2018 22:47
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save slfritchie/6050408a3363ad301c1214921634f601 to your computer and use it in GitHub Desktop.
Save slfritchie/6050408a3363ad301c1214921634f601 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
diff --git a/pony-kafka/kafka_config.pony b/pony-kafka/kafka_config.pony
index 91f6a26..9180c20 100644
--- a/pony-kafka/kafka_config.pony
+++ b/pony-kafka/kafka_config.pony
@@ -438,7 +438,7 @@ class KafkaConfig
consumer_message_handler: KafkaConsumerMessageHandler val = recover val
KafkaHashRoundRobinConsumerMessageHandler end,
compression: KafkaTopicCompressionType = KafkaNoTopicCompression,
- default_consumer_start_offset': ConsumerRequestOffset = KafkaOffsetBeginning,
+ default_consumer_start_offset': ConsumerRequestOffset = 4321,
partitions': (Array[I32] val | Array[(I32, ConsumerRequestOffset)] val | None) = None)
=>
let topic_config = KafkaTopicConfig(topic_name, role,
@@ -474,7 +474,7 @@ class KafkaTopicConfig is Equatable[KafkaTopicConfig box]
consumer_message_handler': KafkaConsumerMessageHandler val = recover val
KafkaHashRoundRobinConsumerMessageHandler end,
compression': KafkaTopicCompressionType = KafkaNoTopicCompression,
- default_consumer_start_offset': ConsumerRequestOffset = KafkaOffsetBeginning,
+ default_consumer_start_offset': ConsumerRequestOffset = 4321,
partitions': (Array[I32] val | Array[(I32, ConsumerRequestOffset)] val | None) = None)
=>
topic_name = topic_name'
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment