По умолчанию потребитель начинает потреблять с последнего зафиксированного смещения, которое, вероятно, является последним смещением в вашем случае.
auto.offset.reset
применяется только тогда, когда нет зафиксированных смещений. Поскольку по умолчанию потребитель автоматически фиксирует смещения, он обычно применяется только при первом запуске (есть несколько других случаев, но они не имеют значения в этом примере).
Таким образом, чтобы видеть поток сообщений, вам нужно либо начать производить, когда ваш потребитель работает, либо использовать другое имя группы, чтобы разрешить применение auto.offset.reset
.
Необходимо преобразовать IDL в typelib сначала:
Что-то как:
midl /I "%VSINSTALLDIR%\DIA SDK\include" dia2.idl /tlb dia2.tlb
tlbimp dia2.tlb
Затем можно импортировать tlb.
Я никогда не использовал SDK DIA этот путь, не знайте, насколько дружественный это было бы. Вы могли также рассмотреть использование его непосредственно от блока управляемого С++ и представления управляемого интерфейса к функциональности, в которой Вы нуждаетесь.