StackRating

An Elo-based rating system for Stack Overflow
Home   |   About   |   Stats and Analysis   |   Get a Badge
Rating Stats for

Michael Heil

Rating
1519.08 (33,850th)
Reputation
15 (1,781,248th)
Page: 1 2 3 ... 8
Title Δ
How to avoid continuous "Resetting offset" and "Seek... -0.03
Does Confluent schema registry only support AVRO? 0.00
Track of consumed messages in Spark structured streaming 0.00
Stream-Static Join: How to refresh (unpersist/persist) static Dataf... 0.00
kafka.common.errors.UnknownProducerIdException 0.00
Spark DeltaLake Upsert (merge) is throwing "org.apache.spark.s... 0.00
Kafka - Setting high linger.ms and batch.size not helping 0.00
Is it possible to achieve at least once semantics using kafka in fl... 0.00
Spark Structured Streaming application reading from Kafka return on... 0.00
How to add field within nested JSON when reading from/writing to Ka... 0.00
Identify and find specific message in Kafka topic 0.00
Spark batch reading from Kafka & using Kafka to keep track of o... +0.51
Writing Spark DataFrame to Kafka is ignoring the partition column a... 0.00
Spark 3.0 - Read data from an MQTT steam 0.00
Why are offsets not reset to 0 after recreating consumer group with... 0.00
When is it appropriate to use a UDF vs using spark functionality? 0.00
Is it possible to configure/code a Kafka consumer application for &... +1.78
How spark calculates the window start time with given window interv... 0.00
Removing one message from a topic in Kafka 0.00
Spark Structured Streaming - AssertionError in Checkpoint due to in... 0.00
Spark Structured Streaming - This query does not support recovering... 0.00
After performing dropDuplicates() am getting different counts when... 0.00
kafka-consumer-groups command doesnt show LAG and CURRENT-OFFSET fo... 0.00
Writing data as JSON array with Spark Structured Streaming 0.00
How to get at least N number of logs from Kafka through Spark? 0.00
Reading schema of streaming Dataframe in Spark Structured Streaming 0.00
Spark: What is the difference between repartition and repartitionBy... +2.04
spark.sql.AnalysisException: Text data source does not support bina... 0.00
Spark Structured Streaming - multiple aggregations without re-readi... 0.00
Kafka delete (tombstone) not updating max aggregate in Spark Struct... 0.00
Read file path from Kafka topic and then read file and write to Del... 0.00
Kafka docs Producer possible message loss 0.00
How to convert a map to individual columns in spark scala? -2.12
Optimal value of spark.sql.shuffle.partitions for a Spark batch Job... 0.00
Spark Scala: functional difference in notation using $? 0.00
Spark isin with multiple list -2.17
Spark Structured Streaming custom partition directory name 0.00
Spark JDBC - How to stop automatic creation of table if table doesn... 0.00
Read data from Kafka and print to console with Spark Structured Sre... 0.00
Use single streaming DataFrame for multiple output streams in PySpa... +0.47
Number Of Parallel Task in Spark Streaming and Kafka Integration 0.00
How to write streaming DataFrame into multiple sinks in Spark Struc... 0.00
How to subscribe to a new topic with subscribePattern? 0.00
How to extract information from a nested XML_String in Spark-Struct... 0.00
Spark DataFrame is not saved in Delta format 0.00
Spring Kafka Consumer Configs - default values and at least once se... 0.00
How do I make a shared queue? 0.00
How to check StreamingQuery performance metrics in Structured Strea... 0.00
Send key in Flink Kafka Producer +2.14
Micronaut-Kafka with auto.commit.enable=false: how commit manually... 0.00