Error getting kafka logs for a JuliaIDE application

[nkottary]

Description of the bug and expected behavior

I expected to get a vector of log messages but I got a stack trace:

ERROR: LoadError: MethodError: no method matching +(::Int64, ::Nothing)

Closest candidates are:
  +(::Any, ::Any, ::Any, ::Any...)
   @ Base operators.jl:578
  +(::T, ::T) where T<:Union{Int128, Int16, Int32, Int64, Int8, UInt128, UInt16, UInt32, UInt64, UInt8}
   @ Base int.jl:87
  +(::Union{Int16, Int32, Int64, Int8}, ::BigInt)
   @ Base gmp.jl:545
  ...

Stacktrace:
  [1] _job_logs_newer!(auth::JuliaHub.Authentication, b::JuliaHub.KafkaLogsBuffer; count::Nothing)
    @ JuliaHub ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging-kafka.jl:150
  [2] _job_logs_newer!
    @ ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging-kafka.jl:116 [inlined]
  [3] #239
    @ ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging.jl:316 [inlined]
  [4] lock(f::JuliaHub.var"#239#240"{Nothing, JuliaHub.Authentication, JuliaHub.KafkaLogsBuffer}, b::JuliaHub.KafkaLogsBuffer)
    @ JuliaHub ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging-kafka.jl:105
  [5] #job_logs_newer!#238
    @ ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging.jl:315 [inlined]
  [6] job_logs_newer!
    @ ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging.jl:309 [inlined]
  [7] job_logs(jobname::String; offset::Int64, limit::Nothing, auth::JuliaHub.Authentication)
    @ JuliaHub ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging.jl:144
  [8] job_logs
    @ ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging.jl:137 [inlined]
  [9] #job_logs#228
    @ ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging.jl:135 [inlined]
 [10] job_logs(job::JuliaHub.Job)
    @ JuliaHub ~/.julia/packages/JuliaHub/ZbObi/src/jobs/logging.jl:135
 [11] top-level scope
    @ ~/Code/logs_test/main.jl:9
in expression starting at /home/nishanth/Code/logs_test/main.jl:9

To Reproduce

Run a JuliaIDE job on your juliahub instance. Use that jobname in the below code:

using JuliaHub

jobname = ARGS[1]
auth = JuliaHub.authenticate("myjuliahubinstance.com")
JuliaHub._OPTION_LoggingMode[] = JuliaHub._LoggingMode.FORCEKAFKA
job = JuliaHub.job(jobname)
ENV["JULIA_DEBUG"]="HTTP"
logs = JuliaHub.job_logs(job)  

println(length(logs))

Environment

branch of JuliaHub.jl: mp/kafka-updates
Instance: juliahub nightly