Evan

#### Proposed Changes: * add grok processor in normalize interceptor #### Which issue(s) this PR fixes: Fixes # https://github.com/loggie-io/loggie/issues/195 #### Additional documentation: > config example: ```docs interceptors: - type: normalize...

Decode from tcp stream

1

**What would you like to be added**: I hope `HessianCodec` can read message from stream, which means body can be from different packet. **Why is this needed**: #### background We...

hello, I want to consume a topic from the latest offset, whatever if it had been consumed with the same groupid before. ``` let consumer: Consumer; let builder = Consumer::from_hosts(brokers)...

``` let mut consumer = Consumer::from_hosts(vec!("localhost:9092".to_owned())) .with_topic_partitions("my-topic".to_owned(), &[0, 1]) .with_fallback_offset(FetchOffset::Earliest) .with_group("my-group".to_owned()) .with_offset_storage(Some(GroupOffsetStorage::Kafka)) .create() .unwrap(); loop { for ms in consumer.poll().unwrap().iter() { for m in ms.messages() { println!("{:?}", m); } consumer.consume_messageset(ms);...

can't find libtinfo.so.6 when install kernel-collector

7

### What happened? ## Description It doesn't work, when I try to install rpm packege ``` libtinfo.so.6(NCURSES6_TINFO_5.0.19991023)(64bit) is needed by opentelemetry-ebpf-kernel-collector-0.10.2-1.x86_64 ``` ## Steps to Reproduce ``` rpm -ivh opentelemetry-ebpf-kernel-collector-0.10.2-1.x86_64.rpm...

https://github.com/twmb/franz-go/issues/591 According this, I think when records will be flushed when linger is hit or batch is full. ``` seeds := strings.Split(brokers, ",") cl, err := kgo.NewClient( kgo.SeedBrokers(seeds...), kgo.ProducerLinger(time.Second*10), kgo.MaxBufferedRecords(5),...