https://pinot.apache.org/ logo
#general
Title
# general
v

Vinod Adwani

12/30/2021, 8:41 AM
Hi folks! I am facing some issues in Kafka stream ingestion in pinot. Pinot is able to connect to Kafka but not able to consume any records or create segments. Can someone please help me?
k

Kartik Khare

12/30/2021, 8:42 AM
Hi Vinod Taking a look at your configs.
`
Copy code
"stream.kafka.bootstrap.servers": "pkc-41p56.asia-south1.gcp.confluent.cloud:9092",
        "stream.kafka.broker.list": "pkc-41p56.asia-south1.gcp.confluent.cloud:9092"
Are these broker hostname pingable from the machines on which pinot is running?
v

Vinod Adwani

12/30/2021, 8:47 AM
yes, Pinot is able to connect to Kafka and able to create a REALTIME table, but not able to insert any records
message has been deleted
k

Kartik Khare

12/30/2021, 8:55 AM
Your json also contains a
b'
in the beginning. Is that accidental or are you publishing the exact same in kafka. Because then it won't be pareseable
v

Vinod Adwani

12/30/2021, 9:12 AM
b
represents byte string
m

Mayank

12/30/2021, 4:43 PM
Could you check the debug endpoint in swagger to see if any server side errors are bubbled up?